net.bluemind.core.rest.tests.services

Class QueueReadStream

java.lang.Object

net.bluemind.core.rest.tests.services.QueueReadStream

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
QueueReadStream()

Method Summary

Modifier and Type	Method and Description
void	end()
QueueReadStream	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
QueueReadStream	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long amount)
QueueReadStream	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
QueueReadStream	pause()
void	queue(io.vertx.core.buffer.Buffer buffer)
QueueReadStream	resume()

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.ReadStream

pipe, pipeTo, pipeTo

Constructor Detail

QueueReadStream

public QueueReadStream()

Method Detail

handler

public QueueReadStream handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

queue

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

end

public void end()

pause

public QueueReadStream pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

resume

public QueueReadStream resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

exceptionHandler

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

Specified by:

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

Specified by:

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

endHandler

public QueueReadStream endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

fetch

public io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> fetch(long amount)

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>