Top Description Inners Fields Constructors Methods
io.rsocket.core

pack-priv Class ClientServerInputMultiplexer

extends Object
implements CoreSubscriber<ByteBuf>, Closeable
Class Inheritance
All Implemented Interfaces
io.rsocket.Closeable, reactor.core.Disposable, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber
Imports
io.netty.buffer.ByteBuf, .ByteBufAllocator, io.rsocket.Closeable, .DuplexConnection, .RSocketErrorException, io.rsocket.frame.FrameHeaderCodec, io.rsocket.plugins.DuplexConnectionInterceptor.Type, .InitializingInterceptorRegistry, java.net.SocketAddress, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, reactor.core.publisher.Flux, .Mono, .Operators
DuplexConnection#receive() is a single stream on which the following type of frames arrive:

The only way to differentiate these two frames is determining whether the stream Id is odd or even. Even IDs are for the streams initiated by server and odds are for streams initiated by the client.

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
ClientServerInputMultiplexer.InternalDuplexConnection

Field Summary

Modifier and TypeField and Description
private final DuplexConnection
clientConnection

private final ClientServerInputMultiplexer.InternalDuplexConnection
clientReceiver

private final boolean
isClient

private Subscription
s

private final DuplexConnection
serverConnection

private final ClientServerInputMultiplexer.InternalDuplexConnection
serverReceiver

private final DuplexConnection
source

private volatile int
state

private static final AtomicIntegerFieldUpdater<ClientServerInputMultiplexer>
STATE

private Throwable
t

Constructor Summary

AccessConstructor and Description
public
ClientServerInputMultiplexer(DuplexConnection source, InitializingInterceptorRegistry registry, boolean isClient)

Method Summary

Modifier and TypeMethod and Description
pack-priv DuplexConnection
asClientConnection()

pack-priv DuplexConnection
asServerConnection()

public void
dispose()

Implements reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.
pack-priv int
incrementAndGetCheckingState()

public boolean
isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.
pack-priv boolean
notifyRequested()

public Mono<Void>
onClose()

Implements io.rsocket.Closeable.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(ByteBuf
the element signaled
frame)

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 String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait