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

Class HttpTransport

java.lang.Object

org.xbib.netty.http.client.transport.HttpTransport

All Implemented Interfaces:

Transport

public class HttpTransport
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.channel.Channel	channel
protected Client	client
protected HttpAddress	httpAddress
protected java.util.SortedMap<java.lang.Integer,Request>	requests
protected java.lang.Throwable	throwable

Fields inherited from interface org.xbib.netty.http.client.transport.Transport

TRANSPORT_ATTRIBUTE_KEY

Constructor Summary

Constructors

Constructor and Description
HttpTransport(Client client, HttpAddress httpAddress)

Method Summary

Modifier and Type	Method and Description
void	awaitResponse(java.lang.Integer streamId)
void	awaitSettings()
void	close()
protected Request	continuation(Request request, io.netty.handler.codec.http.FullHttpResponse httpResponse)
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) Experimental method for executing in a wrapping completable future.
void	fail(java.lang.Throwable throwable)
protected Request	fromStreamId(java.lang.Integer streamId)
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)
protected Request	retry(Request request, io.netty.handler.codec.http.FullHttpResponse httpResponse)
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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

client

protected final Client client

httpAddress

protected final HttpAddress httpAddress

channel

protected io.netty.channel.Channel channel

requests

protected java.util.SortedMap<java.lang.Integer,Request> requests

throwable

protected java.lang.Throwable throwable

Constructor Detail

HttpTransport

public HttpTransport(Client client,
                     HttpAddress httpAddress)

Method Detail

nextStream

public java.lang.Integer nextStream()

settingsReceived

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

awaitSettings

public void awaitSettings()

responseReceived

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

pushPromiseReceived

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

awaitResponse

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

Throws:

java.io.IOException

java.util.concurrent.TimeoutException

get

public Transport get()

success

public void success()

fail

public void fail(java.lang.Throwable throwable)

execute

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

Specified by:

execute in interface Transport

Throws:

java.io.IOException

execute

public <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

Experimental method for executing in a wrapping completable future.

Specified by:

execute in interface Transport

Type Parameters:

T - supplier result

Parameters:

request - request

supplier - supplier

Returns:

completable future

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface Transport

Throws:

java.io.IOException

isFailed

public boolean isFailed()

Specified by:

isFailed in interface Transport

getFailure

public java.lang.Throwable getFailure()

Specified by:

getFailure in interface Transport

headersReceived

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

Specified by:

headersReceived in interface Transport

fromStreamId

protected Request fromStreamId(java.lang.Integer streamId)

continuation

protected Request continuation(Request request,
                               io.netty.handler.codec.http.FullHttpResponse httpResponse)
                        throws org.xbib.net.URLSyntaxException

Throws:

org.xbib.net.URLSyntaxException

retry

protected Request retry(Request request,
                        io.netty.handler.codec.http.FullHttpResponse httpResponse)

setCookieBox

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

Specified by:

setCookieBox in interface Transport

getCookieBox

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

Specified by:

getCookieBox in interface Transport