Uses of Interface
org.forgerock.opendj.io.RxSocket

Packages that use RxSocket

Package	Description
org.forgerock.opendj.io	Classes and interfaces providing I/O functionality.
org.forgerock.opendj.io.rx	Classes and interfaces providing Reactive Streams I/O transports.
org.forgerock.opendj.ldap	Classes and interfaces for core types including connections, entries, and attributes.

Uses of RxSocket in org.forgerock.opendj.io

Classes in org.forgerock.opendj.io with type parameters of type RxSocket

Modifier and Type	Interface	Description
interface	RxServerSocket<M,S extends RxSocket<M>>	A reactive server socket listens for incoming connections and binds them to a RxSocket.
interface	RxTransport<M,S extends RxSocket<M>>	Factory interface for creating reactive client and server sockets.

Subinterfaces of RxSocket in org.forgerock.opendj.io

Modifier and Type	Interface	Description
interface	LdapSocket	A reactive socket implementation representing a stream of LDAP messages.

Uses of RxSocket in org.forgerock.opendj.io.rx

Classes in org.forgerock.opendj.io.rx that implement RxSocket

Modifier and Type	Class	Description
final class	SaslRxSocket	A reactive socket which adds SASL QOP to an underlying reactive socket..
final class	SslRxSocket	A reactive socket implementation which adds SSL to an underlying reactive socket.
final class	SwitchableRxSocket<M>	A reactive socket implementation which delegates to a replaceable delegate reactive socket.
class	TransformedRxSocket<U,D>	A reactive socket which wraps an underlying downstream reactive socket, providing opportunities to transform transferred data or provide additional functionality.

Fields in org.forgerock.opendj.io.rx declared as RxSocket

Modifier and Type	Field	Description
protected RxSocket<D>	TransformedRxSocket.socket	The downstream socket, which may be altered if needed.

Methods in org.forgerock.opendj.io.rx with type parameters of type RxSocket

Modifier and Type	Method	Description
<S extends RxSocket<M>> S	SwitchableRxSocket.getSocket(Class<S> clazz)	Returns the active socket if it has the provided class or null otherwise.
static <D, DS extends RxSocket<D>, U, US extends RxSocket<U>> RxTransport<U,US>	RxIo.transformTransport(String protocol, RxTransport<D,DS> downstream, BiFunction<io.reactivex.rxjava3.core.Single<DS>,Options,io.reactivex.rxjava3.core.Single<US>> connectTransformer, BiFunction<io.reactivex.rxjava3.core.Single<DS>,RxServerSocket<D,DS>,io.reactivex.rxjava3.core.Single<US>> acceptTransformer)	Returns a reactive transport that transforms downstream client and server reactive sockets of type D to upstream sockets of type U.
static <D, DS extends RxSocket<D>, U, US extends RxSocket<U>> RxTransport<U,US>	RxIo.transformTransport(String protocol, RxTransport<D,DS> downstream, BiFunction<io.reactivex.rxjava3.core.Single<DS>,Options,io.reactivex.rxjava3.core.Single<US>> connectTransformer, BiFunction<io.reactivex.rxjava3.core.Single<DS>,RxServerSocket<D,DS>,io.reactivex.rxjava3.core.Single<US>> acceptTransformer)	Returns a reactive transport that transforms downstream client and server reactive sockets of type D to upstream sockets of type U.

Methods in org.forgerock.opendj.io.rx that return RxSocket

Modifier and Type	Method	Description
RxSocket<M>	SwitchableRxSocket.getSocket()	Returns the active socket.

Methods in org.forgerock.opendj.io.rx that return types with arguments of type RxSocket

Modifier and Type	Method	Description
static RxTransport<ByteBuffer,RxSocket<ByteBuffer>>	RxIo.asyncTcpTransport(Options options)	Returns a reactive TCP transport that uses asynchronous non-blocking IO when accepting connections, sending and receiving data.
static RxTransport<ByteBuffer,RxSocket<ByteBuffer>>	RxIo.memoryByteBufferTransport(Options options)	Returns a reactive transport that uses in-memory sockets for all communication.
static <M> RxTransport<M,RxSocket<M>>	RxIo.memoryTransport(Options options)	Returns a reactive transport that uses in-memory sockets for all communication.
static RxTransport<ByteBuffer,RxSocket<ByteBuffer>>	RxIo.syncTcpTransport(Options options)	Returns a reactive TCP transport that uses synchronous blocking IO when accepting connections, sending and receiving data.

Methods in org.forgerock.opendj.io.rx with parameters of type RxSocket

Modifier and Type	Method	Description
static LdapSocket	RxIo.ldapClientSocket(RxSocket<ByteBuffer> socket, Options options)	Returns a reactive socket that adds an LDAP client layer to an underlying socket.
static LdapSocket	RxIo.ldapServerSocket(RxSocket<ByteBuffer> socket, Options options)	Returns a reactive socket that adds an LDAP server layer to an underlying socket.
void	SwitchableRxSocket.resumeReadsAfterSwitchingSocket(RxSocket<M> newSocket)	Replaces the active socket with a new socket and then resumes reading.
static SaslRxSocket	RxIo.saslClientSocket(RxSocket<ByteBuffer> socket, SaslClient saslClient)	Returns a reactive socket that adds a SASL QOP client layer to an underlying socket using the provided authenticated SaslClient.
static SaslRxSocket	RxIo.saslServerSocket(RxSocket<ByteBuffer> socket, SaslServer saslServer)	Returns a reactive socket that adds a SASL QOP server layer to an underlying socket using the provided authenticated SaslServer.
void	SwitchableRxSocket.setSocket(RxSocket<M> newSocket)	Sets the active socket.
static SslRxSocket	RxIo.sslClientSocket(RxSocket<ByteBuffer> socket, Options options)	Returns a reactive socket that adds an SSL client layer to an underlying socket using an SSLEngine obtained from the CommonLdapOptions.SSL_OPTIONS of the provided options and the remote host and port of the provided socket.
static SslRxSocket	RxIo.sslServerSocket(RxSocket<ByteBuffer> socket, Options options)	Returns a reactive socket that adds an SSL server layer to an underlying socket using an SSLEngine obtained from the CommonLdapOptions.SSL_OPTIONS of the provided options.

Method parameters in org.forgerock.opendj.io.rx with type arguments of type RxSocket

Modifier and Type	Method	Description
static RxTransport<LdapMessage,LdapSocket>	RxIo.ldapTransport(RxTransport<ByteBuffer,? extends RxSocket<ByteBuffer>> transport)	Returns a reactive transport that adds an LDAP layer to an underlying transport.
static RxTransport<ByteBuffer,SslRxSocket>	RxIo.sslTransport(RxTransport<ByteBuffer,? extends RxSocket<ByteBuffer>> transport)	Returns a reactive transport that adds an SSL layer to an underlying transport.

Constructors in org.forgerock.opendj.io.rx with parameters of type RxSocket

Modifier	Constructor	Description
	SwitchableRxSocket(RxSocket<M> socket)	Returns a new switchable socket delegating to the provided downstream socket.
protected	TransformedRxSocket(RxSocket<D> socket)	Returns a new transformed socket delegating to the provided downstream socket.

Uses of RxSocket in org.forgerock.opendj.ldap

Fields in org.forgerock.opendj.ldap with type parameters of type RxSocket

Modifier and Type	Field	Description
static final Option<io.reactivex.rxjava3.functions.Consumer<RxSocket<?>>>	LdapServer.ACCEPTED_CLIENT_VALIDATOR	A consumer which is invoked immediately after a new connection has been accepted in order to determine whether the connection should be accepted or not, in which case it will be closed immediately.