echo/io.github.alexandrepiveteau.echo/ReceiveExchange

ReceiveExchange

fun interface ReceiveExchange<out I, in O>
Content copied to clipboard

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

Parameters

I

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

O

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

Functions

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

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

Inheritors

Link copied to clipboard

Extensions

Link copied to clipboard
fun <I, O> ReceiveExchange<I, O>.asReceiveExchange(): ReceiveExchange<I, O>
Content copied to clipboard

Returns the ReceiveExchange.