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

Packages that use RxTransport

Package	Description
org.forgerock.opendj.io.rx	Classes and interfaces providing Reactive Streams I/O transports.

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

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

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<LdapMessage,LdapSocket>	RxIo.ldapMemoryTransport(Options options)	Returns an in-memory reactive LDAP transport.
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<LdapMessage,LdapSocket>	RxIo.ldapTransportFromOptions(Options options)	Returns a new LDAP RxTransport configured using the provided options.
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,SslRxSocket>	RxIo.sslTransport(RxTransport<ByteBuffer,? extends RxSocket<ByteBuffer>> transport)	Returns a reactive transport that adds an SSL layer to an underlying transport.
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.
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 with parameters of type RxTransport

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.
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.