ByteBufferTransport

Properties

val scope: CoroutineScope

open override fun handle(event: ControllerEvent)

fun handle(controller: Unit, event: ControllerEvent)

operator fun <Result> invoke(function: Unit.() -> Result?): Result?

suspend fun <Result> invokeSuspend(function: suspend Unit.() -> Result?): Result?

open override fun onReceiveFlow(payload: FlexPayload): Flow<FlexPayload>

open override fun onReceiveSingle(payload: FlexPayload)

open override fun sendAsync(payload: FlexPayload): Flow<FlexPayload>

open override fun sendSync(payload: FlexPayload): FlexPayload