services.moleculer.httpclient

Class PacketStreamBody

java.lang.Object

services.moleculer.httpclient.PacketStreamBody

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.asynchttpclient.request.body.Body

public class PacketStreamBody
extends java.lang.Object
implements org.asynchttpclient.request.body.Body

PacketStream-based request body.

Nested Class Summary

Nested classes/interfaces inherited from interface org.asynchttpclient.request.body.Body

org.asynchttpclient.request.body.Body.BodyState

Field Summary

Fields

Modifier and Type	Field and Description
protected long	contentLength
protected java.util.concurrent.ConcurrentLinkedQueue<byte[]>	queue
protected services.moleculer.stream.PacketStream	stream

Constructor Summary

Constructors

Constructor and Description
PacketStreamBody(services.moleculer.stream.PacketStream stream, long contentLength)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getContentLength()
void	setListener(org.asynchttpclient.request.body.generator.FeedListener listener)
org.asynchttpclient.request.body.Body.BodyState	transferTo(io.netty.buffer.ByteBuf target)

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected final java.util.concurrent.ConcurrentLinkedQueue<byte[]> queue

stream

protected final services.moleculer.stream.PacketStream stream

contentLength

protected final long contentLength

Constructor Detail

PacketStreamBody

public PacketStreamBody(services.moleculer.stream.PacketStream stream,
                        long contentLength)

Method Detail

setListener

public void setListener(org.asynchttpclient.request.body.generator.FeedListener listener)

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getContentLength

public long getContentLength()

Specified by:

getContentLength in interface org.asynchttpclient.request.body.Body

transferTo

public org.asynchttpclient.request.body.Body.BodyState transferTo(io.netty.buffer.ByteBuf target)
                                                           throws java.io.IOException

Specified by:

transferTo in interface org.asynchttpclient.request.body.Body

Throws:

java.io.IOException