net.bluemind.eas.http.wbxml.internal

Class StreamConsumer

java.lang.Object

net.bluemind.eas.http.wbxml.internal.StreamConsumer

All Implemented Interfaces:

io.vertx.core.Handler<io.vertx.core.buffer.Buffer>

public class StreamConsumer
extends java.lang.Object
implements io.vertx.core.Handler<io.vertx.core.buffer.Buffer>

Field Summary

Fields

Modifier and Type	Field and Description
boolean	corrupted

Constructor Summary

Constructors

Constructor and Description
StreamConsumer(AuthorizedDeviceQuery query)

Method Summary

Modifier and Type	Method and Description
void	dispose()
void	handle(io.vertx.core.buffer.Buffer event)
com.google.common.io.ByteSource	inputStream()
boolean	isEmptyRequestBody()
void	markEnd()

Methods inherited from class java.lang.Object

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

Field Detail

corrupted

public boolean corrupted

Constructor Detail

StreamConsumer

public StreamConsumer(AuthorizedDeviceQuery query)

Method Detail

inputStream

public com.google.common.io.ByteSource inputStream()
                                            throws java.io.IOException

Throws:

java.io.IOException

isEmptyRequestBody

public boolean isEmptyRequestBody()

handle

public void handle(io.vertx.core.buffer.Buffer event)

Specified by:

handle in interface io.vertx.core.Handler<io.vertx.core.buffer.Buffer>

markEnd

public void markEnd()

dispose

public void dispose()