publish

@MessageMapping(value = ["stream"])

fun publish(@Payload(required = false) inBoundMessages: Flow<ByteArray>, @DestinationVariable client: String): Flow<RSocketResponse>

Flow variant of publishSingleMessage as request/stream RSocket API.

Returns a stream of HubPayload encoded in ProtoBuf only in case of error. Otherwise, in case of success the payload is empty.