Top Description Inners Methods
io.rsocket.transport

public Interface ServerTransport<T extends io.rsocket.Closeable>

extends Transport
Imports
io.rsocket.Closeable, .DuplexConnection, java.util.function.Function, org.reactivestreams.Publisher, reactor.core.publisher.Mono
A server contract for writing transports of RSocket.

Nested and Inner Type Summary

Modifier and TypeClass and Description
public static interface
ServerTransport.ConnectionAcceptor

A contract to accept a new DuplexConnection.

Method Summary

Modifier and TypeMethod and Description
public Mono<T>

Returns:

A handle for information about and control over the server.
start(ServerTransport.ConnectionAcceptor
to process a newly accepted connections with
acceptor)

Start this server.

Inherited from io.rsocket.transport.Transport:
maxFrameLength

Method Detail

startback to summary
public Mono<T> start(ServerTransport.ConnectionAcceptor acceptor)

Start this server.

Parameters
acceptor:ServerTransport.ConnectionAcceptor

to process a newly accepted connections with

Returns:Mono<T>

A handle for information about and control over the server.

Since
1.0.1
io.rsocket.transport back to summary

public Interface ServerTransport.ConnectionAcceptor

extends Function<DuplexConnection, Publisher<Void>>
A contract to accept a new DuplexConnection.

Method Summary

Modifier and TypeMethod and Description
public Mono<Void>

Returns:

A Publisher which terminates when the processing of the connection finishes.
apply(DuplexConnection
New DuplexConnection to be processed.
duplexConnection)

Redeclares java.util.function.Function.apply.

Accept a new DuplexConnection and returns Publisher signifying the end of processing of the connection.
Inherited from java.util.function.Function:
andThencomposeidentity

Method Detail

applyback to summary
public Mono<Void> apply(DuplexConnection duplexConnection)

Redeclares java.util.function.Function.apply.

Accept a new DuplexConnection and returns Publisher signifying the end of processing of the connection.

Parameters
duplexConnection:DuplexConnection

New DuplexConnection to be processed.

Returns:Mono<Void>

A Publisher which terminates when the processing of the connection finishes.

Annotations
@Override