echo/io.github.alexandrepiveteau.echo/Site

Site

interface Site<out M> : Exchange<Message.Incoming, Message.Outgoing>
Content copied to clipboard

An interface describing a Site in the distributed system. When collected, it will emit the latest aggregated model.

Parameters

M

the type of the underlying aggregated model for this Site.

Functions

Link copied to clipboard
abstract fun receive(incoming: Flow<Message.Outgoing>): Flow<Message.Incoming>
Content copied to clipboard

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

Link copied to clipboard
abstract fun send(incoming: Flow<Message.Incoming>): Flow<Message.Outgoing>
Content copied to clipboard

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

Properties

Link copied to clipboard
abstract val value: Flow<M>
Content copied to clipboard

Returns the current value.

Inheritors

Link copied to clipboard