suspend fun Builder.connectAndAwait(transport: ClientTransport): RSocketRequester
Coroutines variant of RSocketRequester.Builder.connect. |
|
suspend fun Builder.connectTcpAndAwait(host: String, port: Int): RSocketRequester
Coroutines variant of RSocketRequester.Builder.connectTcp. |
|
suspend fun Builder.connectWebSocketAndAwait(uri: URI): RSocketRequester
Coroutines variant of RSocketRequester.Builder.connectWebSocket. |
|
fun <T : Any> RequestSpec.dataFlow(data: Flow<T>): ResponseSpec
Kotlin Flow variant of RSocketRequester.RequestSpec.data. |
|
suspend fun <T : Any> ResponseSpec.retrieveAndAwait(): T
Coroutines variant of RSocketRequester.ResponseSpec.retrieveMono. |
|
fun <T : Any> ResponseSpec.retrieveFlow(batchSize: Int = 1): Flow<T>
Coroutines variant of RSocketRequester.ResponseSpec.retrieveFlux. |
|
suspend fun ResponseSpec.sendAndAwait(): Unit
Coroutines variant of RSocketRequester.ResponseSpec.send. |