public class NettyRSocketServer extends Object implements RSocketServer
RSocketServer
that is based on a Reactor Netty server. Usually this class
should be created using the NettyRSocketServerFactory
and not directly.RSocketServer.Transport
Constructor and Description |
---|
NettyRSocketServer(reactor.core.publisher.Mono<io.rsocket.transport.netty.server.CloseableChannel> starter,
Duration lifecycleTimeout) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
address()
Return the address this server is listening on.
|
void |
start()
Starts the RSocket server.
|
void |
stop()
Stops the RSocket server.
|
public NettyRSocketServer(reactor.core.publisher.Mono<io.rsocket.transport.netty.server.CloseableChannel> starter, Duration lifecycleTimeout)
public InetSocketAddress address()
RSocketServer
address
in interface RSocketServer
public void start() throws RSocketServerException
RSocketServer
start
in interface RSocketServer
RSocketServerException
- if the server cannot be startedpublic void stop() throws RSocketServerException
RSocketServer
stop
in interface RSocketServer
RSocketServerException
- if the server cannot be stopped