Package-level declarations

Types

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
interface StreamBuilderScope<Event, Response> : CoroutineScope
Link copied to clipboard
Link copied to clipboard
class StreamTestReceiver<Event, Response>(coroutineScope: CoroutineScope, receiveStream: ReceiveStream<Event, Response>)
Link copied to clipboard
@Target(allowedTargets = [AnnotationTarget.CLASS])
annotation class WithLog(val scope: String)

Annotation for classes that will get a LOG companion extension property for logging.

Link copied to clipboard
sealed interface XmlView

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.