net.bluemind.node.client.impl.ahc

Class DefaultAsyncHandler<T>

java.lang.Object

net.bluemind.node.client.impl.ahc.DefaultAsyncHandler<T>

All Implemented Interfaces:

org.asynchttpclient.AsyncHandler<T>

Direct Known Subclasses:

ActiveExecutionsHandler, DeleteHandler, InterruptHandler, ListFilesHandler, PingHandler, ReadHandler, StatusHandler, SubmitHandler, WriteHandler

public abstract class DefaultAsyncHandler<T>
extends java.lang.Object
implements org.asynchttpclient.AsyncHandler<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.asynchttpclient.AsyncHandler

org.asynchttpclient.AsyncHandler.State

Field Summary

Fields

Modifier and Type	Field and Description
protected FileBackedOutputStream	body
protected int	status

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultAsyncHandler(boolean bodyExpected)
protected	DefaultAsyncHandler(java.lang.String stackInfos, boolean bodyExpected)

Method Summary

Modifier and Type	Method and Description
protected abstract T	getResult(int status, io.netty.handler.codec.http.HttpHeaders headers, FileBackedOutputStream body)
org.asynchttpclient.AsyncHandler.State	onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
T	onCompleted()
org.asynchttpclient.AsyncHandler.State	onHeadersReceived(io.netty.handler.codec.http.HttpHeaders headers)
org.asynchttpclient.AsyncHandler.State	onStatusReceived(org.asynchttpclient.HttpResponseStatus responseStatus)
void	onThrowable(java.lang.Throwable t)
org.asynchttpclient.BoundRequestBuilder	prepare(org.asynchttpclient.BoundRequestBuilder rb)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.asynchttpclient.AsyncHandler

onConnectionOffer, onConnectionPoolAttempt, onConnectionPooled, onHostnameResolutionAttempt, onHostnameResolutionFailure, onHostnameResolutionSuccess, onRequestSend, onRetry, onTcpConnectAttempt, onTcpConnectFailure, onTcpConnectSuccess, onTlsHandshakeAttempt, onTlsHandshakeFailure, onTlsHandshakeSuccess, onTrailingHeadersReceived

Field Detail

body

protected final FileBackedOutputStream body

status

protected int status

Constructor Detail

DefaultAsyncHandler

protected DefaultAsyncHandler(boolean bodyExpected)

DefaultAsyncHandler

protected DefaultAsyncHandler(java.lang.String stackInfos,
                              boolean bodyExpected)

Method Detail

onThrowable

public void onThrowable(java.lang.Throwable t)

Specified by:

onThrowable in interface org.asynchttpclient.AsyncHandler<T>

onBodyPartReceived

public org.asynchttpclient.AsyncHandler.State onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
                                                          throws java.lang.Exception

Specified by:

onBodyPartReceived in interface org.asynchttpclient.AsyncHandler<T>

Throws:

java.lang.Exception

onStatusReceived

public org.asynchttpclient.AsyncHandler.State onStatusReceived(org.asynchttpclient.HttpResponseStatus responseStatus)
                                                        throws java.lang.Exception

Specified by:

onStatusReceived in interface org.asynchttpclient.AsyncHandler<T>

Throws:

java.lang.Exception

onHeadersReceived

public org.asynchttpclient.AsyncHandler.State onHeadersReceived(io.netty.handler.codec.http.HttpHeaders headers)
                                                         throws java.lang.Exception

Specified by:

onHeadersReceived in interface org.asynchttpclient.AsyncHandler<T>

Throws:

java.lang.Exception

onCompleted

public T onCompleted()
              throws java.lang.Exception

Specified by:

onCompleted in interface org.asynchttpclient.AsyncHandler<T>

Throws:

java.lang.Exception

getResult

protected abstract T getResult(int status,
                               io.netty.handler.codec.http.HttpHeaders headers,
                               FileBackedOutputStream body)

prepare

public org.asynchttpclient.BoundRequestBuilder prepare(org.asynchttpclient.BoundRequestBuilder rb)