net.bluemind.imap.vertx.tests

Class SlowSink

java.lang.Object

net.bluemind.imap.vertx.tests.SlowSink

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
SlowSink()

Method Summary

Modifier and Type	Method and Description
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>	drainHandler(io.vertx.core.Handler<java.lang.Void> handler)
void	end()
void	end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
boolean	ended()
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
long	length()
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>	setWriteQueueMaxSize(int maxSize)
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>	write(io.vertx.core.buffer.Buffer data)
io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>	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

Constructor Detail

SlowSink

public SlowSink()

Method Detail

exceptionHandler

public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> 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>

write

public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> write(io.vertx.core.buffer.Buffer data)

Specified by:

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

length

public long length()

ended

public boolean ended()

write

public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> 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 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>

setWriteQueueMaxSize

public io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> 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 io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> drainHandler(io.vertx.core.Handler<java.lang.Void> handler)

Specified by:

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