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