Package org.springframework.messaging.rsocket

Functions

Link copied to clipboard
suspend fun RSocketRequester.Builder.connectAndAwait(transport: ClientTransport): RSocketRequester

Coroutines variant of RSocketRequester.Builder.connect.

Link copied to clipboard
suspend fun RSocketRequester.Builder.connectTcpAndAwait(host: String, port: Int): RSocketRequester
Link copied to clipboard
suspend fun RSocketRequester.Builder.connectWebSocketAndAwait(uri: URI): RSocketRequester
Link copied to clipboard
inline fun <T : Any> RSocketRequester.RequestSpec.dataWithType(producer: Any): RSocketRequester.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.

inline fun <T : Any> RSocketRequester.RequestSpec.dataWithType(flow: Flow<T>): RSocketRequester.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.

inline fun <T : Any> RSocketRequester.RequestSpec.dataWithType(publisher: Publisher<T>): RSocketRequester.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.

Link copied to clipboard
inline fun <T : Any> MetadataExtractorRegistry.metadataToExtract(mimeType: MimeType, noinline mapper: (T, MutableMap<String, Any>) -> Unit)
inline fun <T : Any> MetadataExtractorRegistry.metadataToExtract(mimeType: MimeType, name: String? = null)

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.

Link copied to clipboard
inline suspend fun <T : Any> RSocketRequester.RetrieveSpec.retrieveAndAwait(): T
Link copied to clipboard
inline suspend fun <T : Any> RSocketRequester.RetrieveSpec.retrieveAndAwaitOrNull(): T?

Nullable coroutines variant of RSocketRequester.RetrieveSpec.retrieveMono.

Link copied to clipboard
inline fun <T : Any> RSocketRequester.RetrieveSpec.retrieveFlow(): Flow<T>
Link copied to clipboard
inline fun <T : Any> RSocketRequester.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.

Link copied to clipboard
inline fun <T : Any> RSocketRequester.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.

Link copied to clipboard
suspend fun RSocketRequester.RetrieveSpec.sendAndAwait()

Coroutines variant of RSocketRequester.RetrieveSpec.send.