Package org.xbib.netty.http.client.api

Interface Transport

All Superinterfaces:

java.lang.AutoCloseable

public interface Transport
extends java.lang.AutoCloseable

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	close()
Transport	execute(Request request)
<T> java.util.concurrent.CompletableFuture<T>	execute(Request request, java.util.function.Function<org.xbib.netty.http.common.HttpResponse,T> supplier)
void	fail(java.lang.Throwable throwable)
Transport	get()
Transport	get(long value, java.util.concurrent.TimeUnit timeUnit)
org.xbib.netty.http.common.cookie.CookieBox	getCookieBox()
java.lang.Throwable	getFailure()
org.xbib.netty.http.common.HttpAddress	getHttpAddress()
javax.net.ssl.SSLSession	getSession()
boolean	isFailed()
void	pushPromiseReceived(io.netty.channel.Channel channel, java.lang.Integer streamId, java.lang.Integer promisedStreamId, io.netty.handler.codec.http2.Http2Headers headers)
void	responseReceived(io.netty.channel.Channel channel, java.lang.Integer streamId, io.netty.handler.codec.http.FullHttpResponse fullHttpResponse)
void	setCookieBox(org.xbib.netty.http.common.cookie.CookieBox cookieBox)
void	settingsReceived(io.netty.handler.codec.http2.Http2Settings http2Settings)
void	waitForSettings()

Field Detail

TRANSPORT_ATTRIBUTE_KEY

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

Method Detail

getHttpAddress

org.xbib.netty.http.common.HttpAddress getHttpAddress()

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<org.xbib.netty.http.common.HttpResponse,T> supplier)
                                               throws java.io.IOException

Throws:

java.io.IOException

waitForSettings

void waitForSettings()

settingsReceived

void settingsReceived(io.netty.handler.codec.http2.Http2Settings http2Settings)
               throws java.io.IOException

Throws:

java.io.IOException

responseReceived

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

Throws:

java.io.IOException

pushPromiseReceived

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

setCookieBox

void setCookieBox(org.xbib.netty.http.common.cookie.CookieBox cookieBox)

getCookieBox

org.xbib.netty.http.common.cookie.CookieBox getCookieBox()

get

Transport get()

get

Transport get(long value,
              java.util.concurrent.TimeUnit timeUnit)

cancel

void cancel()

fail

void fail(java.lang.Throwable throwable)

isFailed

boolean isFailed()

getFailure

java.lang.Throwable getFailure()

getSession

javax.net.ssl.SSLSession getSession()

close

void close()
    throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException