Uses of Interface org.forgerock.opendj.io.RxSocket (OpenAM Server Only 7.3.1 Documentation)

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
`class`	`SaslRxSocket`	A reactive socket which adds SASL QOP to an underlying reactive socket..
`class`	`SslRxSocket`	A reactive socket implementation which adds SSL to an underlying reactive socket.
`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
Constructor	Description
`SwitchableRxSocket(RxSocket<M> socket)`	Returns a new switchable socket delegating to the provided downstream socket.
`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 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.