IN
- The type that will be received by this serverOUT
- The type that will be sent by this serverpublic class NettyHttpServer<IN,OUT> extends HttpServer<IN,OUT>
TcpServer
implementationModifier and Type | Field and Description |
---|---|
protected TcpServer<IN,OUT> |
server |
routedWriters
started
Modifier | Constructor and Description |
---|---|
protected |
NettyHttpServer(Environment env,
Dispatcher dispatcher,
InetSocketAddress listenAddress,
ServerSocketOptions options,
SslOptions sslOptions,
Codec<Buffer,IN,OUT> codec) |
Modifier and Type | Method and Description |
---|---|
protected void |
bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
io.netty.channel.socket.SocketChannel nativeChannel) |
protected Promise<Void> |
doShutdown() |
protected Promise<Void> |
doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
InetSocketAddress |
getListenAddress()
Get the address to which this server is bound.
|
protected void |
onWebsocket(HttpChannel<IN,OUT> next) |
protected Iterable<? extends org.reactivestreams.Publisher<Void>> |
routeChannel(HttpChannel<IN,OUT> ch) |
delete, get, hasWebsocketEndpoints, post, put, route, start, ws
getDefaultCodec, getDefaultDispatcher, getDefaultEnvironment, getDefaultPrefetchSize, shutdown, start
protected NettyHttpServer(Environment env, Dispatcher dispatcher, InetSocketAddress listenAddress, ServerSocketOptions options, SslOptions sslOptions, Codec<Buffer,IN,OUT> codec)
public InetSocketAddress getListenAddress()
HttpServer
getListenAddress
in class HttpServer<IN,OUT>
protected Promise<Void> doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
doStart
in class ReactorPeer<IN,OUT,HttpChannel<IN,OUT>>
protected Iterable<? extends org.reactivestreams.Publisher<Void>> routeChannel(HttpChannel<IN,OUT> ch)
routeChannel
in class HttpServer<IN,OUT>
protected void onWebsocket(HttpChannel<IN,OUT> next)
onWebsocket
in class HttpServer<IN,OUT>
protected final Promise<Void> doShutdown()
doShutdown
in class ReactorPeer<IN,OUT,HttpChannel<IN,OUT>>
protected void bindChannel(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler, io.netty.channel.socket.SocketChannel nativeChannel)
Copyright © 2016. All rights reserved.