send

@MessageMapping(value = ["stream"])

suspend fun send(@DestinationVariable client: String): Flow<RSocketResponse>

Stream a Flow of MessageWithId as request/stream RSocket API. Takes nothing as argument in payload. In metadata takes the client path as String.

Returns a HubPayload encoded in ProtoBuf format with data an MessageWithId. Streams OutgoingMessages, which are meant only for the listening client.

Whenever a client connects to this API, he receives on start every message stored in database for him and then the streaming begins.