services.moleculer.httpclient

Class ResponseToOutputStream

java.lang.Object

services.moleculer.httpclient.ResponseHandler

services.moleculer.httpclient.ResponseToOutputStream

All Implemented Interfaces:

org.asynchttpclient.AsyncHandler<io.datatree.Tree>

public class ResponseToOutputStream
extends ResponseHandler

Redirects response into the specific OutputStream (eg. into file, database blob, etc).

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 java.io.OutputStream	target
protected java.util.concurrent.atomic.AtomicLong	transfered

Fields inherited from class services.moleculer.httpclient.ResponseHandler

httpHeaders, params, status

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ResponseToOutputStream(RequestParams params, java.io.OutputStream target)

Method Summary

Modifier and Type	Method and Description
protected void	closeStream()
org.asynchttpclient.AsyncHandler.State	onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
io.datatree.Tree	onCompleted()
void	onThrowable(java.lang.Throwable t)

Methods inherited from class services.moleculer.httpclient.ResponseHandler

addStatusAndHeaders, onHeadersReceived, onStatusReceived

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

target

protected final java.io.OutputStream target

transfered

protected final java.util.concurrent.atomic.AtomicLong transfered

Constructor Detail

ResponseToOutputStream

protected ResponseToOutputStream(RequestParams params,
                                 java.io.OutputStream target)

Method Detail

onThrowable

public void onThrowable(java.lang.Throwable t)

Specified by:

onThrowable in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Overrides:

onThrowable in class ResponseHandler

onBodyPartReceived

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

Specified by:

onBodyPartReceived in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Specified by:

onBodyPartReceived in class ResponseHandler

Throws:

java.lang.Exception

onCompleted

public io.datatree.Tree onCompleted()
                             throws java.lang.Exception

Specified by:

onCompleted in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>

Specified by:

onCompleted in class ResponseHandler

Throws:

java.lang.Exception

closeStream

protected void closeStream()