public class NettyRSocketServer extends java.lang.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,
java.time.Duration lifecycleTimeout) |
Modifier and Type | Method and Description |
---|---|
java.net.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, java.time.Duration lifecycleTimeout)
public java.net.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