General design

// initialize the communicator, this can be based on TCP, MPI or UCX Communicator comm;

// initialize the operation Join join(&comm, KEY_TYPE, LEFT_DATA_TYPE, RIGHT_DATA_TYPE)

// insert multiple tuples for (i = 0 ; i < 100; i++) { if (!join.join(msg)) { // if we cannot accept the messages join.progress(); } }

// wait until the join completes join.wait();