org.springframework.messaging.rsocket

spring-framework / org.springframework.messaging.rsocket

Package org.springframework.messaging.rsocket

Functions

connectAndAwait	`suspend fun Builder.connectAndAwait(transport: ClientTransport): RSocketRequester` Coroutines variant of RSocketRequester.Builder.connect.
connectTcpAndAwait	`suspend fun Builder.connectTcpAndAwait(host: String, port: Int): RSocketRequester` Coroutines variant of RSocketRequester.Builder.connectTcp.
connectWebSocketAndAwait	`suspend fun Builder.connectWebSocketAndAwait(uri: URI): RSocketRequester` Coroutines variant of RSocketRequester.Builder.connectWebSocket.
dataWithType	`fun <T : Any> RequestSpec.dataWithType(producer: Any): RetrieveSpec` Extension for RSocketRequester.RequestSpec.data providing a `dataWithType<Foo>(Any)` variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments. `fun <T : Any> RequestSpec.dataWithType(publisher: Publisher<T>): RetrieveSpec` Extension for RSocketRequester.RequestSpec.data providing a `dataWithType(Publisher<T>)` variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments. `fun <T : Any> RequestSpec.dataWithType(flow: Flow<T>): RetrieveSpec` Extension for RSocketRequester.RequestSpec.data providing a `dataWithType(Flow<T>)` variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments.
metadataToExtract	`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 `metadataToExtract<Foo>(...)` variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments.
retrieveAndAwait	`suspend fun <T : Any> RetrieveSpec.retrieveAndAwait(): T` Coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.
retrieveAndAwaitOrNull	`suspend fun <T : Any> RetrieveSpec.retrieveAndAwaitOrNull(): T?` Nullable coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.
retrieveFlow	`fun <T : Any> RetrieveSpec.retrieveFlow(): Flow<T>` Coroutines variant of RSocketRequester.RetrieveSpec.retrieveFlux.
retrieveFlux	`fun <T : Any> RetrieveSpec.retrieveFlux(): Flux<T>` Extension for RSocketRequester.RetrieveSpec.retrieveFlux providing a `retrieveFlux<Foo>()` variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments.
retrieveMono	`fun <T : Any> RetrieveSpec.retrieveMono(): Mono<T>` Extension for RSocketRequester.RetrieveSpec.retrieveMono providing a `retrieveMono<Foo>()` variant leveraging Kotlin reified type parameters. This extension is not subject to type erasure and retains actual generic type arguments.
sendAndAwait	`suspend fun RetrieveSpec.sendAndAwait(): Unit` Coroutines variant of RSocketRequester.RetrieveSpec.send.