public class ResponseToPacketStream extends ResponseHandler
| Modifier and Type | Field and Description |
|---|---|
protected services.moleculer.stream.PacketStream |
target |
httpHeaders, params, status| Modifier | Constructor and Description |
|---|---|
protected |
ResponseToPacketStream(RequestParams params,
services.moleculer.stream.PacketStream target) |
| 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) |
addStatusAndHeaders, onHeadersReceived, onStatusReceivedclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonConnectionOffer, onConnectionPoolAttempt, onConnectionPooled, onHostnameResolutionAttempt, onHostnameResolutionFailure, onHostnameResolutionSuccess, onRequestSend, onRetry, onTcpConnectAttempt, onTcpConnectFailure, onTcpConnectSuccess, onTlsHandshakeAttempt, onTlsHandshakeFailure, onTlsHandshakeSuccess, onTrailingHeadersReceivedprotected ResponseToPacketStream(RequestParams params, services.moleculer.stream.PacketStream target)
public void onThrowable(java.lang.Throwable t)
onThrowable in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>onThrowable in class ResponseHandlerpublic org.asynchttpclient.AsyncHandler.State onBodyPartReceived(org.asynchttpclient.HttpResponseBodyPart bodyPart)
throws java.lang.Exception
onBodyPartReceived in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>onBodyPartReceived in class ResponseHandlerjava.lang.Exceptionpublic io.datatree.Tree onCompleted()
throws java.lang.Exception
onCompleted in interface org.asynchttpclient.AsyncHandler<io.datatree.Tree>onCompleted in class ResponseHandlerjava.lang.Exceptionprotected void closeStream()