net.bluemind.core.rest.tests.services

Class AccumulatorStream

java.lang.Object

net.bluemind.core.rest.tests.services.AccumulatorStream

All Implemented Interfaces:

org.vertx.java.core.streams.DrainSupport<AccumulatorStream>, org.vertx.java.core.streams.ExceptionSupport<AccumulatorStream>, org.vertx.java.core.streams.WriteStream<AccumulatorStream>

public class AccumulatorStream
extends java.lang.Object
implements org.vertx.java.core.streams.WriteStream<AccumulatorStream>

Constructor Summary

Constructors

Constructor and Description
AccumulatorStream()

Method Summary

Modifier and Type	Method and Description
org.vertx.java.core.buffer.Buffer	buffer()
AccumulatorStream	drainHandler(org.vertx.java.core.Handler<java.lang.Void> handler)
AccumulatorStream	exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> handler)
AccumulatorStream	setWriteQueueMaxSize(int maxSize)
AccumulatorStream	write(org.vertx.java.core.buffer.Buffer data)
boolean	writeQueueFull()

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumulatorStream

public AccumulatorStream()

Method Detail

exceptionHandler

public AccumulatorStream exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> handler)

Specified by:

exceptionHandler in interface org.vertx.java.core.streams.ExceptionSupport<AccumulatorStream>

setWriteQueueMaxSize

public AccumulatorStream setWriteQueueMaxSize(int maxSize)

Specified by:

setWriteQueueMaxSize in interface org.vertx.java.core.streams.DrainSupport<AccumulatorStream>

writeQueueFull

public boolean writeQueueFull()

Specified by:

writeQueueFull in interface org.vertx.java.core.streams.DrainSupport<AccumulatorStream>

drainHandler

public AccumulatorStream drainHandler(org.vertx.java.core.Handler<java.lang.Void> handler)

Specified by:

drainHandler in interface org.vertx.java.core.streams.DrainSupport<AccumulatorStream>

write

public AccumulatorStream write(org.vertx.java.core.buffer.Buffer data)

Specified by:

write in interface org.vertx.java.core.streams.WriteStream<AccumulatorStream>

buffer

public org.vertx.java.core.buffer.Buffer buffer()