Package | Description |
---|---|
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 |
---|---|
protected static AtomicIntegerFieldUpdater<HttpChannel> |
HttpChannel.HEADERS_SENT |
protected Registry<HttpChannel,ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>>> |
HttpServer.routedWriters |
protected Registry<HttpChannel,ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>>> |
HttpServer.routedWriters |
Modifier and Type | Method and Description |
---|---|
HttpChannel<IN,OUT> |
HttpChannel.addHeader(String name,
String value)
Accumulate a Request Header using the given name and value, appending ";" for each new value
|
HttpChannel<IN,OUT> |
HttpChannel.addResponseHeader(String name,
String value)
Accumulate a response HTTP header for the given key name, appending ";" for each new value
|
HttpChannel<IN,OUT> |
HttpChannel.header(String name,
String value)
Register an HTTP request header
|
abstract HttpChannel<IN,OUT> |
HttpChannel.keepAlive(boolean keepAlive)
set the request keepAlive if true otherwise remove the existing connection keep alive header
|
HttpChannel<IN,OUT> |
HttpChannel.responseHeader(String name,
String value)
Define the response HTTP header for the given key
|
HttpChannel<IN,OUT> |
HttpChannel.responseStatus(Status status)
Set the response status to an outgoing response
|
HttpChannel<IN,OUT> |
HttpChannel.sse() |
abstract HttpChannel<IN,OUT> |
HttpChannel.transfer(Transfer transfer)
Define the Transfer mode for this http connection
|
Modifier and Type | Method and Description |
---|---|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.delete(String url)
HTTP DELETE the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.delete(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP DELETE the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.get(String url)
HTTP GET the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.get(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP GET the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.post(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP POST the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.put(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP PUT the passed URL.
|
abstract Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Use the passed HTTP method to send to the given URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.ws(String url)
WebSocket to the passed URL.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.ws(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
WebSocket to the passed URL.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HttpSelector.matches(HttpChannel key) |
protected abstract void |
HttpServer.onWebsocket(HttpChannel<IN,OUT> next) |
protected Iterable<? extends org.reactivestreams.Publisher<Void>> |
HttpServer.routeChannel(HttpChannel<IN,OUT> ch) |
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.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.delete(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP DELETE the passed URL.
|
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.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.get(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP GET the passed URL.
|
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.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.post(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP POST the passed URL.
|
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.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.put(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
HTTP PUT the passed URL.
|
abstract Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
Use the passed HTTP method to send to the given URL.
|
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.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.
|
Promise<? extends HttpChannel<IN,OUT>> |
HttpClient.ws(String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler)
WebSocket to the passed URL.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyHttpChannel<IN,OUT> |
Modifier and Type | Method and Description |
---|---|
HttpChannel<IN,OUT> |
NettyHttpChannel.keepAlive(boolean keepAlive) |
HttpChannel<IN,OUT> |
NettyHttpChannel.transfer(Transfer transfer) |
Modifier and Type | Method and Description |
---|---|
Promise<? extends HttpChannel<IN,OUT>> |
NettyHttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
NettyHttpServer.onWebsocket(HttpChannel<IN,OUT> next) |
protected Iterable<? extends org.reactivestreams.Publisher<Void>> |
NettyHttpServer.routeChannel(HttpChannel<IN,OUT> ch) |
Modifier and Type | Method and Description |
---|---|
protected Promise<Void> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
protected Promise<Void> |
NettyHttpServer.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler,
Reconnect reconnect) |
Promise<? extends HttpChannel<IN,OUT>> |
NettyHttpClient.request(Method method,
String url,
ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler) |
Copyright © 2017. All rights reserved.