Package org.xbib.netty.http.client.transport

Interface Transport

All Known Implementing Classes:

Http2Transport, HttpTransport

public interface Transport

Field Summary

Fields

Modifier and Type	Field and Description
static io.netty.util.AttributeKey<Transport>	TRANSPORT_ATTRIBUTE_KEY

Method Summary

Modifier and Type	Method and Description
void	awaitResponse(java.lang.Integer streamId)
void	awaitSettings()
void	close()
Transport	execute(Request request)
<T> java.util.concurrent.CompletableFuture<T>	execute(Request request, java.util.function.Function<io.netty.handler.codec.http.FullHttpResponse,T> supplier)
void	fail(java.lang.Throwable throwable)
Transport	get()
java.util.Map<io.netty.handler.codec.http.cookie.Cookie,java.lang.Boolean>	getCookieBox()
java.lang.Throwable	getFailure()
void	headersReceived(java.lang.Integer streamId, io.netty.handler.codec.http.HttpHeaders httpHeaders)
boolean	isFailed()
java.lang.Integer	nextStream()
void	pushPromiseReceived(java.lang.Integer streamId, java.lang.Integer promisedStreamId, io.netty.handler.codec.http2.Http2Headers headers)
void	responseReceived(java.lang.Integer streamId, io.netty.handler.codec.http.FullHttpResponse fullHttpResponse)
void	setCookieBox(java.util.Map<io.netty.handler.codec.http.cookie.Cookie,java.lang.Boolean> cookieBox)
void	settingsReceived(io.netty.channel.Channel channel, io.netty.handler.codec.http2.Http2Settings http2Settings)
void	success()

Field Detail

TRANSPORT_ATTRIBUTE_KEY

static final io.netty.util.AttributeKey<Transport> TRANSPORT_ATTRIBUTE_KEY

Method Detail

execute

Transport execute(Request request)
           throws java.io.IOException

Throws:

java.io.IOException

execute

<T> java.util.concurrent.CompletableFuture<T> execute(Request request,
                                                      java.util.function.Function<io.netty.handler.codec.http.FullHttpResponse,T> supplier)
                                               throws java.io.IOException

Throws:

java.io.IOException

nextStream

java.lang.Integer nextStream()

settingsReceived

void settingsReceived(io.netty.channel.Channel channel,
                      io.netty.handler.codec.http2.Http2Settings http2Settings)

awaitSettings

void awaitSettings()

setCookieBox

void setCookieBox(java.util.Map<io.netty.handler.codec.http.cookie.Cookie,java.lang.Boolean> cookieBox)

getCookieBox

java.util.Map<io.netty.handler.codec.http.cookie.Cookie,java.lang.Boolean> getCookieBox()

responseReceived

void responseReceived(java.lang.Integer streamId,
                      io.netty.handler.codec.http.FullHttpResponse fullHttpResponse)

headersReceived

void headersReceived(java.lang.Integer streamId,
                     io.netty.handler.codec.http.HttpHeaders httpHeaders)

pushPromiseReceived

void pushPromiseReceived(java.lang.Integer streamId,
                         java.lang.Integer promisedStreamId,
                         io.netty.handler.codec.http2.Http2Headers headers)

awaitResponse

void awaitResponse(java.lang.Integer streamId)
            throws java.io.IOException,
                   java.util.concurrent.TimeoutException

Throws:

java.io.IOException

java.util.concurrent.TimeoutException

get

Transport get()

success

void success()

fail

void fail(java.lang.Throwable throwable)

isFailed

boolean isFailed()

getFailure

java.lang.Throwable getFailure()

close

void close()
    throws java.io.IOException

Throws:

java.io.IOException