services.moleculer.httpclient

Class PacketStreamBodyGenerator

java.lang.Object

services.moleculer.httpclient.PacketStreamBodyGenerator

All Implemented Interfaces:

org.asynchttpclient.request.body.generator.BodyGenerator, org.asynchttpclient.request.body.generator.FeedableBodyGenerator

public class PacketStreamBodyGenerator
extends java.lang.Object
implements org.asynchttpclient.request.body.generator.FeedableBodyGenerator

PacketStream-based HTTP body generator.

Field Summary

Fields

Modifier and Type	Field and Description
protected PacketStreamBody	body

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
org.asynchttpclient.request.body.Body	createBody()
boolean	feed(io.netty.buffer.ByteBuf buffer, boolean isLast)
void	setListener(org.asynchttpclient.request.body.generator.FeedListener listener)

Methods inherited from class java.lang.Object

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

Field Detail

body

protected final PacketStreamBody body

Constructor Detail

PacketStreamBodyGenerator

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

Method Detail

createBody

public org.asynchttpclient.request.body.Body createBody()

Specified by:

createBody in interface org.asynchttpclient.request.body.generator.BodyGenerator

feed

public boolean feed(io.netty.buffer.ByteBuf buffer,
                    boolean isLast)
             throws java.lang.Exception

Specified by:

feed in interface org.asynchttpclient.request.body.generator.FeedableBodyGenerator

Throws:

java.lang.Exception

setListener

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

Specified by:

setListener in interface org.asynchttpclient.request.body.generator.FeedableBodyGenerator