public class NettyHttpChannel<IN,OUT> extends HttpChannel<IN,OUT>
ReactorChannel.ConsumerSpec
HEADERS_SENT, HTTP_SCHEME, HTTPS_SCHEME, WS_SCHEME, WSS_SCHEME
log
Constructor and Description |
---|
NettyHttpChannel(NettyChannelStream<IN,OUT> tcpStream,
io.netty.handler.codec.http.HttpRequest request) |
Modifier and Type | Method and Description |
---|---|
io.netty.channel.socket.SocketChannel |
delegate() |
protected void |
doAddHeader(String name,
String value) |
protected void |
doAddResponseHeader(String name,
String value) |
protected void |
doDecoded(IN in) |
protected void |
doHeader(String name,
String value) |
protected void |
doResponseHeader(String name,
String value) |
void |
doResponseStatus(Status status) |
protected void |
doSubscribeWriter(org.reactivestreams.Publisher<? extends OUT> writer,
org.reactivestreams.Subscriber<? super Void> postWriter) |
io.netty.handler.codec.http.HttpRequest |
getNettyRequest() |
io.netty.handler.codec.http.HttpResponse |
getNettyResponse() |
NettyHttpHeaders |
headers() |
boolean |
isKeepAlive()
Is the request keepAlive
|
HttpChannel<IN,OUT> |
keepAlive(boolean keepAlive)
set the request keepAlive if true otherwise remove the existing connection keep alive header
|
Method |
method() |
ReactorChannel.ConsumerSpec |
on()
Assign event handlers to certain channel lifecycle events.
|
Protocol |
protocol() |
InetSocketAddress |
remoteAddress()
Get the address of the remote peer.
|
NettyHttpResponseHeaders |
responseHeaders() |
Status |
responseStatus() |
void |
subscribe(org.reactivestreams.Subscriber<? super IN> subscriber) |
Transfer |
transfer() |
HttpChannel<IN,OUT> |
transfer(Transfer transfer)
Define the Transfer mode for this http connection
|
String |
uri() |
addHeader, addResponseHeader, header, param, params, responseHeader, responseStatus, sse
getCapacity, getDecoder, getDispatcher, getEncoder, getEnvironment, writeBufferWith, writeWith
adaptiveConsume, adaptiveConsumeOn, after, batchConsume, batchConsumeOn, broadcast, broadcastOn, broadcastTo, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cancelSubscription, capacity, cast, combine, concatMap, concatWith, consume, consume, consume, consume, consume, consumeLater, consumeOn, consumeOn, consumeOn, count, count, decode, defaultIfEmpty, dematerialize, dispatchOn, dispatchOn, dispatchOn, distinct, distinct, distinctUntilChanged, distinctUntilChanged, downstreamSubscription, elapsed, elementAt, elementAtOrDefault, encode, env, exists, fanIn, filter, filter, finallyDo, flatMap, getTimer, groupBy, ignoreError, ignoreError, isReactivePull, join, joinWith, keepAlive, last, lift, log, log, map, materialize, merge, mergeWith, nest, next, observe, observeCancel, observeComplete, observeError, observeStart, observeSubscribe, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturn, onOverflowBuffer, onOverflowBuffer, onOverflowDrop, partition, partition, process, recover, reduce, reduce, repeat, repeat, repeatWhen, requestWhen, retry, retry, retry, retry, retryWhen, sample, sample, sample, sample, sample, sample, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, scan, scan, skip, skip, skip, skipWhile, skipWhile, sort, sort, sort, sort, split, split, startWith, startWith, startWith, subscribe, subscribeOn, subscribeOn, subscribeOn, switchMap, take, take, take, takeWhile, tap, throttle, throttle, timeout, timeout, timeout, timeout, timestamp, toBlockingQueue, toBlockingQueue, toList, toList, toString, unbounded, when, window, window, window, window, window, window, window, window, window, window, window, zip, zipWith, zipWith
public NettyHttpChannel(NettyChannelStream<IN,OUT> tcpStream, io.netty.handler.codec.http.HttpRequest request)
protected void doSubscribeWriter(org.reactivestreams.Publisher<? extends OUT> writer, org.reactivestreams.Subscriber<? super Void> postWriter)
doSubscribeWriter
in class ChannelStream<IN,OUT>
protected void doDecoded(IN in)
doDecoded
in class ChannelStream<IN,OUT>
public void subscribe(org.reactivestreams.Subscriber<? super IN> subscriber)
public Protocol protocol()
protocol
in class HttpChannel<IN,OUT>
protected void doHeader(String name, String value)
doHeader
in class HttpChannel<IN,OUT>
protected void doAddHeader(String name, String value)
doAddHeader
in class HttpChannel<IN,OUT>
public String uri()
uri
in class HttpChannel<IN,OUT>
public Method method()
method
in class HttpChannel<IN,OUT>
public NettyHttpHeaders headers()
headers
in class HttpChannel<IN,OUT>
public io.netty.handler.codec.http.HttpRequest getNettyRequest()
public Status responseStatus()
responseStatus
in class HttpChannel<IN,OUT>
public void doResponseStatus(Status status)
doResponseStatus
in class HttpChannel<IN,OUT>
public Transfer transfer()
transfer
in class HttpChannel<IN,OUT>
public HttpChannel<IN,OUT> transfer(Transfer transfer)
HttpChannel
transfer
in class HttpChannel<IN,OUT>
transfer
- the new transfer modepublic NettyHttpResponseHeaders responseHeaders()
responseHeaders
in class HttpChannel<IN,OUT>
protected void doResponseHeader(String name, String value)
doResponseHeader
in class HttpChannel<IN,OUT>
protected void doAddResponseHeader(String name, String value)
doAddResponseHeader
in class HttpChannel<IN,OUT>
public io.netty.handler.codec.http.HttpResponse getNettyResponse()
public io.netty.channel.socket.SocketChannel delegate()
delegate
in class ChannelStream<IN,OUT>
public InetSocketAddress remoteAddress()
ReactorChannel
public ReactorChannel.ConsumerSpec on()
ReactorChannel
public boolean isKeepAlive()
HttpChannel
isKeepAlive
in class HttpChannel<IN,OUT>
public HttpChannel<IN,OUT> keepAlive(boolean keepAlive)
HttpChannel
keepAlive
in class HttpChannel<IN,OUT>
Copyright © 2017. All rights reserved.