SendAndReceive

data class SendAndReceive(val sessionToMessage: Map<FlowSession, SerializedBytes<Any>>, val shouldRetrySend: Boolean) : FlowIORequest<Map<FlowSession, SerializedBytes<Any>>>

Send and receive messages from the specified sessions.

Return

a map from session to received message.

Constructors

Link copied to clipboard
constructor(sessionToMessage: Map<FlowSession, SerializedBytes<Any>>, shouldRetrySend: Boolean)

Properties

Link copied to clipboard

a map from session to message-to-be-sent. The keys also specify which sessions to receive from.

Link copied to clipboard

specifies whether the send should be retried.

Functions

Link copied to clipboard
open override fun toString(): String