Top Description Inners Fields Constructors Methods
io.rsocket.core

pack-priv Class DefaultRSocketClient

extends ResolvingOperator<RSocket>
implements CoreSubscriber<RSocket>, CorePublisher<RSocket>, RSocketClient
Class Inheritance
All Implemented Interfaces
io.rsocket.core.RSocketClient, io.rsocket.Closeable, reactor.core.Disposable, reactor.core.CorePublisher, org.reactivestreams.Publisher, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber
Imports
io.netty.util.IllegalReferenceCountException, .ReferenceCounted, io.rsocket.Payload, .RSocket, io.rsocket.frame.FrameType, java.util.AbstractMap, .Map, java.util.concurrent.atomic.AtomicReferenceFieldUpdater, java.util.function.Consumer, java.util.stream.Stream, org.reactivestreams.Publisher, .Subscriber, .Subscription, reactor.core.CorePublisher, .CoreSubscriber, .Scannable, reactor.core.publisher.Flux, .Mono, .MonoOperator, .Operators, .Sinks, reactor.util.annotation.Nullable, reactor.util.context.Context
Default implementation of RSocketClient
Since
1.0.1

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
DefaultRSocketClient.FlatMapMain<R>

pack-priv static class
DefaultRSocketClient.FlattingInner<T>

pack-priv static class
DefaultRSocketClient.RequestChannelInner

pack-priv static class
DefaultRSocketClient.RSocketClientFluxOperator<ST extends Publisher<Payload>>

pack-priv static class
DefaultRSocketClient.RSocketClientMonoOperator<T>

Field Summary

Modifier and TypeField and Description
pack-priv static final Consumer<ReferenceCounted>
DISCARD_ELEMENTS_CONSUMER

pack-priv static final Object
ON_DISCARD_KEY

pack-priv final Sinks.Empty<Void>
onDisposeSink

pack-priv volatile Subscription
s

pack-priv static final AtomicReferenceFieldUpdater<DefaultRSocketClient, Subscription>
S

pack-priv final Mono<RSocket>
source

Inherited from io.rsocket.core.ResolvingOperator:
ADDED_STATEEMPTY_SUBSCRIBEDEMPTY_UNSUBSCRIBEDON_DISPOSEREADYREADY_STATEsubscribersSUBSCRIBERStTERMINATEDTERMINATED_STATEvaluewipWIP

Constructor Summary

AccessConstructor and Description
pack-priv
DefaultRSocketClient(Mono<RSocket> source)

Method Summary

Modifier and TypeMethod and Description
protected void
doOnDispose()

Overrides io.rsocket.core.ResolvingOperator.doOnDispose.

protected void
doOnValueExpired(RSocket value)

Overrides io.rsocket.core.ResolvingOperator.doOnValueExpired.

protected void
doOnValueResolved(RSocket value)

Overrides io.rsocket.core.ResolvingOperator.doOnValueResolved.

protected void
doSubscribe()

Overrides io.rsocket.core.ResolvingOperator.doSubscribe.

public Mono<Void>
fireAndForget(Mono<Payload> payloadMono)

Implements io.rsocket.core.RSocketClient.fireAndForget.

Perform a Fire-and-Forget interaction via RSocket#fireAndForget(Payload).
public Mono<Void>
metadataPush(Mono<Payload> payloadMono)

Implements io.rsocket.core.RSocketClient.metadataPush.

Perform a Metadata Push via RSocket#metadataPush(Payload).
public Mono<Void>
onClose()

Overrides default io.rsocket.core.RSocketClient.onClose.

Returns a Mono that terminates when the instance is terminated by any reason.
public void
onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.
public void
onError(Throwable
the throwable signaled
t)

Implements org.reactivestreams.Subscriber.onError.

Failed terminal state.
public void
onNext(RSocket
the element signaled
value)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
public void
onSubscribe(Subscription
the Subscription that allows requesting data via Subscription#request(long)
s)

Implements reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by onNext(Object) before calling Subscription#request(long).
public Flux<Payload>
requestChannel(Publisher<Payload> payloads)

Implements io.rsocket.core.RSocketClient.requestChannel.

Perform a Request-Channel interaction via RSocket#requestChannel(Publisher).
public Mono<Payload>
requestResponse(Mono<Payload> payloadMono)

Implements io.rsocket.core.RSocketClient.requestResponse.

Perform a Request-Response interaction via RSocket#requestResponse(Payload).
public Flux<Payload>
requestStream(Mono<Payload> payloadMono)

Implements io.rsocket.core.RSocketClient.requestStream.

Perform a Request-Stream interaction via RSocket#requestStream(Payload).
public Mono<RSocket>
source()

Implements io.rsocket.core.RSocketClient.source.

Return the underlying source used to obtain a shared RSocket connection.
public void
subscribe(CoreSubscriber<? super RSocket>
the Subscriber interested into the published sequence
actual)

Implements reactor.core.CorePublisher.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.
public void
subscribe(Subscriber<? super RSocket>
the Subscriber that will consume signals from this Publisher
s)

Implements org.reactivestreams.Publisher.subscribe.

Request Publisher to start streaming data.
private Mono<RSocket>
unwrapReconnectMono(Mono<RSocket> source)

Inherited from io.rsocket.core.ResolvingOperator:
addblockcompleteconnectdisposedoFinallyinvalidateisDisposedisPendingobserveremoveterminatevalueIfResolved