SendExchange

fun interface SendExchange<in I, out O>

An interface defining an asymmetrical replication site, biased towards sending data.

Parameters

I

the type of the domain-specific incoming events for this SendExchange.

O

the type of the domain-specific outgoing events for this SendExchange.

Functions

Link copied to clipboard
abstract fun send(incoming: Flow<I>): Flow<O>

Sends some O as a response to an incoming of I.

Inheritors

Link copied to clipboard

Extensions

Link copied to clipboard
fun <I, O> SendExchange<I, O>.asSendExchange(): SendExchange<I, O>

Returns the SendExchange.