net.bluemind.core.rest.base

Class MonitoredReadStream

java.lang.Object

net.bluemind.core.rest.base.MonitoredReadStream

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor and Description
MonitoredReadStream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream, BMExecutor.BMTaskMonitor monitor)

Method Summary

Modifier and Type	Method and Description
MonitoredReadStream	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
MonitoredReadStream	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long amount)
MonitoredReadStream	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
MonitoredReadStream	pause()
MonitoredReadStream	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

MonitoredReadStream

public MonitoredReadStream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream,
                           BMExecutor.BMTaskMonitor monitor)

Method Detail

handler

public MonitoredReadStream 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>

pause

public MonitoredReadStream pause()

Specified by:

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

resume

public MonitoredReadStream resume()

Specified by:

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

exceptionHandler

public MonitoredReadStream 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 MonitoredReadStream 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>