syncAll

suspend fun <I, O> syncAll(vararg exchanges: Exchange<I, O>)

Syncs the provided Exchange until they are all done communicating. The syncAll operator creates some pairs of Exchange, forming a fully connected graph.

Because a fully connected graph is created, some Exchange may transitively sync messages, event if their direct connections are stopped. The degenerate case of this topology is a single exchange, which will not sync at all.

Parameters

I

the type of the incoming messages.

O

the type of the outgoing messages.