Top Description Inners Fields Constructors Methods

io.rsocket

pack-priv Class RSocketAdapter

Class Inheritance

extends Object

java.lang.Object
io.rsocket.RSocketAdapter

Imports

org.reactivestreams.Publisher, reactor.core.publisher.Flux, .Mono

Package private class with default implementations for use in RSocket. The main purpose is to hide static UnsupportedOperationException declarations.

Since: 1.0.3

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static class	RSocketAdapter.UnsupportedInteractionException

Field Summary

Modifier and Type	Field and Description
private static final Mono<Void>	UNSUPPORTED_FIRE_AND_FORGET
private static final Mono<Void>	UNSUPPORTED_METADATA_PUSH
private static final Flux<Payload>	UNSUPPORTED_REQUEST_CHANNEL
private static final Mono<Payload>	UNSUPPORTED_REQUEST_RESPONSE
private static final Flux<Payload>	UNSUPPORTED_REQUEST_STREAM

Constructor Summary

Access	Constructor and Description
pack-priv	RSocketAdapter()

Method Summary

Modifier and Type	Method and Description
pack-priv static Mono<Void>	fireAndForget(Payload payload)
pack-priv static Mono<Void>	metadataPush(Payload payload)
pack-priv static Flux<Payload>	requestChannel(Publisher<Payload> payloads)
pack-priv static Mono<Payload>	requestResponse(Payload payload)
pack-priv static Flux<Payload>	requestStream(Payload payload)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

UNSUPPORTED_FIRE_AND_FORGET	back to summary
private static final Mono<Void> UNSUPPORTED_FIRE_AND_FORGET

UNSUPPORTED_METADATA_PUSH	back to summary
private static final Mono<Void> UNSUPPORTED_METADATA_PUSH

UNSUPPORTED_REQUEST_CHANNEL	back to summary
private static final Flux<Payload> UNSUPPORTED_REQUEST_CHANNEL

UNSUPPORTED_REQUEST_RESPONSE	back to summary
private static final Mono<Payload> UNSUPPORTED_REQUEST_RESPONSE

UNSUPPORTED_REQUEST_STREAM	back to summary
private static final Flux<Payload> UNSUPPORTED_REQUEST_STREAM

Constructor Detail

RSocketAdapter	back to summary
pack-priv RSocketAdapter()

Method Detail

fireAndForget	back to summary
pack-priv static Mono<Void> fireAndForget(Payload payload)

metadataPush	back to summary
pack-priv static Mono<Void> metadataPush(Payload payload)

requestChannel	back to summary
pack-priv static Flux<Payload> requestChannel(Publisher<Payload> payloads)

requestResponse	back to summary
pack-priv static Mono<Payload> requestResponse(Payload payload)

requestStream	back to summary
pack-priv static Flux<Payload> requestStream(Payload payload)

io.rsocket back to summary

private Class RSocketAdapter.UnsupportedInteractionException

Class Inheritance

extends RuntimeException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
io.rsocket.RSocketAdapter.UnsupportedInteractionException

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides java.lang.RuntimeException.serialVersionUID.

Constructor Summary

Access	Constructor and Description
pack-priv	UnsupportedInteractionException(String interactionName)

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.lang.RuntimeException.serialVersionUID.

Constructor Detail

UnsupportedInteractionException	back to summary
pack-priv UnsupportedInteractionException(String interactionName)