net.bluemind.core.rest.tests.services

Class AccumulatorStream

java.lang.Object

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

All Implemented Interfaces:

io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

public class AccumulatorStream
extends java.lang.Object
implements io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

Field Summary

Fields

Modifier and Type	Field and Description
int	call

Constructor Summary

Constructors

Constructor and Description
AccumulatorStream()

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertx.core.streams.WriteStream

end, end

Field Detail

call

public int call

Constructor Detail

AccumulatorStream

public AccumulatorStream()

Method Detail

exceptionHandler

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

Specified by:

exceptionHandler in interface io.vertx.core.streams.StreamBase

Specified by:

exceptionHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

setWriteQueueMaxSize

public AccumulatorStream setWriteQueueMaxSize(int maxSize)

Specified by:

setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

writeQueueFull

public boolean writeQueueFull()

Specified by:

writeQueueFull in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

drainHandler

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

Specified by:

drainHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

write

public io.vertx.core.Future<java.lang.Void> write(io.vertx.core.buffer.Buffer data)

Specified by:

write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

buffer

public io.vertx.core.buffer.Buffer buffer()

write

public void write(io.vertx.core.buffer.Buffer data,
                  io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

end

public io.vertx.core.Future<java.lang.Void> end()

Specified by:

end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

end

public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>