Package-level declarations
Types
Link copied to clipboard
Link copied to clipboard
Kotlin-only implementation of a bi-directional stream.
Link copied to clipboard
An RPC-like stream for returning responses to sent events. The main use case is communication between the JVM and native code, but it can be used for any bi-directional communication.
Link copied to clipboard
An RPC-like stream for sending events and receiving responses for those events. The main use case is communication between the JVM and native code, but it can be used for any bi-directional communication.
Link copied to clipboard
Link copied to clipboard
class StreamLedger
Link copied to clipboard
class StreamTestReceiver<Event, Response>(coroutineScope: CoroutineScope, receiveStream: ReceiveStream<Event, Response>)
Link copied to clipboard
Annotation for classes that will get a LOG companion extension property for logging.
Functions
Link copied to clipboard
suspend fun <Event, Response> SendStream<Event, Response>.sendAndExpectResponse(event: Event, expectedResponse: Response, actions: suspend () -> Unit)
Link copied to clipboard
fun <Event, Response> stream(coroutineScope: CoroutineScope, scope: suspend StreamBuilderScope<Event, Response>.() -> Unit): ReceiveStream<Event, Response>
Creates a new ReceiveStream and runs the given scope in a new coroutine. The scope can use the StreamBuilderScope.send method to send events to the sender of the stream.