Package | Description |
---|---|
reactor.io.net |
Reactive network components are located in this package scope implementing the following exposed contract:
A
ReactorPeer NetServer/NetClient is a Publisher of
ReactorChannel that are themselves Publisher of input data. |
reactor.io.net.http |
Components for writing HTTP-based clients and servers using Reactor abstractions.
|
reactor.io.net.impl.netty.http |
Modifier and Type | Field and Description |
---|---|
static Class<? extends HttpServer> |
NetStreams.DEFAULT_HTTP_SERVER_TYPE |
Modifier and Type | Method and Description |
---|---|
protected HttpServer<IN,OUT> |
Spec.HttpServerSpec.configure(Dispatcher dispatcher,
Environment env) |
static HttpServer<Buffer,Buffer> |
NetStreams.httpServer()
Build a simple Netty HTTP server listening on 127.0.0.1 and 12012
|
static <IN,OUT> HttpServer<IN,OUT> |
NetStreams.httpServer(Class<? extends HttpServer> serverFactory,
Function<? super Spec.HttpServerSpec<IN,OUT>,? extends Spec.HttpServerSpec<IN,OUT>> configuringFunction) |
static <IN,OUT> HttpServer<IN,OUT> |
NetStreams.httpServer(Function<? super Spec.HttpServerSpec<IN,OUT>,? extends Spec.HttpServerSpec<IN,OUT>> configuringFunction)
Build a Netty HTTP Server with the passed factory
|
static HttpServer<Buffer,Buffer> |
NetStreams.httpServer(int port)
Build a simple Netty HTTP server listening on 127.0.0.1 and the passed port
|
static HttpServer<Buffer,Buffer> |
NetStreams.httpServer(String bindAddress)
Build a simple Netty HTTP server listening on 127.0.0.1 and 12012
|
static HttpServer<Buffer,Buffer> |
NetStreams.httpServer(String bindAddress,
int port)
Build a simple Netty HTTP server listening othe passed bind address and port
|
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> HttpServer<IN,OUT> |
NetStreams.httpServer(Class<? extends HttpServer> serverFactory,
Function<? super Spec.HttpServerSpec<IN,OUT>,? extends Spec.HttpServerSpec<IN,OUT>> configuringFunction) |
Modifier and Type | Method and Description |
---|---|
HttpServer<IN,OUT> |
HttpServer.delete(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP DELETE on the passed path to be used as a routing condition.
|
HttpServer<IN,OUT> |
HttpServer.get(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP GET on the passed path to be used as a routing condition.
|
HttpServer<IN,OUT> |
HttpServer.post(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP POST on the passed path to be used as a routing condition.
|
HttpServer<IN,OUT> |
HttpServer.put(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for HTTP PUT on the passed path to be used as a routing condition.
|
HttpServer<IN,OUT> |
HttpServer.route(Selector<HttpChannel> condition,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> serviceFunction)
Register an handler for the given Selector condition, incoming connections will query the internal registry
to invoke the matching handlers.
|
HttpServer<IN,OUT> |
HttpServer.ws(String path,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Listen for WebSocket on the passed path to be used as a routing condition.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyHttpServer<IN,OUT>
A Netty-based
TcpServer implementation |
Copyright © 2016. All rights reserved.