spring-framework / org.springframework.messaging.rsocket

Package org.springframework.messaging.rsocket

Functions

connectAndAwait

Coroutines variant of RSocketRequester.Builder.connect.

suspend fun Builder.connectAndAwait(transport: ClientTransport): RSocketRequester

connectTcpAndAwait

Coroutines variant of RSocketRequester.Builder.connectTcp.

suspend fun Builder.connectTcpAndAwait(host: String, port: Int): RSocketRequester

connectWebSocketAndAwait

Coroutines variant of RSocketRequester.Builder.connectWebSocket.

suspend fun Builder.connectWebSocketAndAwait(uri: URI): RSocketRequester

dataWithType

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(producer: Any): 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(publisher: Publisher<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.

fun <T : Any> RequestSpec.dataWithType(flow: Flow<T>): RetrieveSpec

metadataToExtract

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.

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

retrieveAndAwait

Coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.

suspend fun <T : Any> RetrieveSpec.retrieveAndAwait(): T

retrieveAndAwaitOrNull

Nullable coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.

suspend fun <T : Any> RetrieveSpec.retrieveAndAwaitOrNull(): T?

retrieveFlow

Coroutines variant of RSocketRequester.RetrieveSpec.retrieveFlux.

fun <T : Any> RetrieveSpec.retrieveFlow(): Flow<T>

retrieveFlux

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.

fun <T : Any> RetrieveSpec.retrieveFlux(): Flux<T>

retrieveMono

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.

fun <T : Any> RetrieveSpec.retrieveMono(): Mono<T>

sendAndAwait

Coroutines variant of RSocketRequester.RetrieveSpec.send.

suspend fun RetrieveSpec.sendAndAwait(): Unit