io.vertx.core.http.impl

Interface HttpClientStream

public interface HttpClientStream

Author:

Julien Viet

Method Summary

Modifier and Type	Method and Description
void	chunkHandler(Handler<Buffer> handler)
void	closeHandler(Handler<Void> handler)
HttpClientConnection	connection()
void	continueHandler(Handler<Void> handler)
void	doFetch(long amount)
void	doPause()
void	doSetWriteQueueMaxSize(int size)
void	drainHandler(Handler<Void> handler)
void	endHandler(Handler<MultiMap> handler)
void	exceptionHandler(Handler<Throwable> handler)
ContextInternal	getContext()
void	headHandler(Handler<HttpResponseHead> handler)
int	id()
boolean	isNotWritable()
Object	metric()
StreamPriority	priority()
void	priorityHandler(Handler<StreamPriority> handler)
void	pushHandler(Handler<HttpClientPush> handler)
void	reset(Throwable cause)
void	unknownFrameHandler(Handler<HttpFrame> handler)
void	updatePriority(StreamPriority streamPriority)
HttpVersion	version()
void	writeBuffer(io.netty.buffer.ByteBuf buf, boolean end, Handler<AsyncResult<Void>> listener)
void	writeFrame(int type, int flags, io.netty.buffer.ByteBuf payload)
void	writeHead(HttpRequestHead request, boolean chunked, io.netty.buffer.ByteBuf buf, boolean end, StreamPriority priority, boolean connect, Handler<AsyncResult<Void>> handler)

Method Detail

id

int id()

Returns:

the stream id, 1 denotes the first stream, HTTP/1 is a simple sequence, HTTP/2 is the actual stream identifier.

metric

Object metric()

version

HttpVersion version()

Returns:

the stream version or null if it's not yet determined

connection

HttpClientConnection connection()

getContext

ContextInternal getContext()

writeHead

void writeHead(HttpRequestHead request,
               boolean chunked,
               io.netty.buffer.ByteBuf buf,
               boolean end,
               StreamPriority priority,
               boolean connect,
               Handler<AsyncResult<Void>> handler)

writeBuffer

void writeBuffer(io.netty.buffer.ByteBuf buf,
                 boolean end,
                 Handler<AsyncResult<Void>> listener)

writeFrame

void writeFrame(int type,
                int flags,
                io.netty.buffer.ByteBuf payload)

continueHandler

void continueHandler(Handler<Void> handler)

drainHandler

void drainHandler(Handler<Void> handler)

pushHandler

void pushHandler(Handler<HttpClientPush> handler)

unknownFrameHandler

void unknownFrameHandler(Handler<HttpFrame> handler)

exceptionHandler

void exceptionHandler(Handler<Throwable> handler)

headHandler

void headHandler(Handler<HttpResponseHead> handler)

chunkHandler

void chunkHandler(Handler<Buffer> handler)

endHandler

void endHandler(Handler<MultiMap> handler)

priorityHandler

void priorityHandler(Handler<StreamPriority> handler)

closeHandler

void closeHandler(Handler<Void> handler)

doSetWriteQueueMaxSize

void doSetWriteQueueMaxSize(int size)

isNotWritable

boolean isNotWritable()

doPause

void doPause()

doFetch

void doFetch(long amount)

reset

void reset(Throwable cause)

priority

StreamPriority priority()

updatePriority

void updatePriority(StreamPriority streamPriority)