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.dataWithType(producer: Any): RetrieveSpec
Extension for RSocketRequester.RequestSpec.data providing a fun <T : Any> RequestSpec.dataWithType(publisher: Publisher<T>): RetrieveSpec
Extension for RSocketRequester.RequestSpec.data providing a fun <T : Any> RequestSpec.dataWithType(flow: Flow<T>): RetrieveSpec
Extension for RSocketRequester.RequestSpec.data providing a |
|
fun <T : Any> MetadataExtractorRegistry.metadataToExtract(mimeType: MimeType, name: String? = null): Unit fun <T : Any> MetadataExtractorRegistry.metadataToExtract(mimeType: MimeType, mapper: (T, MutableMap<String, Any>) -> Unit): Unit
Extension for MetadataExtractorRegistry.metadataToExtract providing a |
|
suspend fun <T : Any> RetrieveSpec.retrieveAndAwait(): T
Coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono. |
|
suspend fun <T : Any> RetrieveSpec.retrieveAndAwaitOrNull(): T?
Nullable coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono. |
|
fun <T : Any> RetrieveSpec.retrieveFlow(): Flow<T>
Coroutines variant of RSocketRequester.RetrieveSpec.retrieveFlux. |
|
fun <T : Any> RetrieveSpec.retrieveFlux(): Flux<T>
Extension for RSocketRequester.RetrieveSpec.retrieveFlux providing a |
|
fun <T : Any> RetrieveSpec.retrieveMono(): Mono<T>
Extension for RSocketRequester.RetrieveSpec.retrieveMono providing a |
|
suspend fun RetrieveSpec.sendAndAwait(): Unit
Coroutines variant of RSocketRequester.RetrieveSpec.send. |