net.bluemind.core.rest.base

Class MonitoredReadStream

java.lang.Object

net.bluemind.core.rest.base.MonitoredReadStream

All Implemented Interfaces:

org.vertx.java.core.streams.ExceptionSupport<MonitoredReadStream>, org.vertx.java.core.streams.ReadStream<MonitoredReadStream>, org.vertx.java.core.streams.ReadSupport<MonitoredReadStream,org.vertx.java.core.buffer.Buffer>

public class MonitoredReadStream
extends java.lang.Object
implements org.vertx.java.core.streams.ReadStream<MonitoredReadStream>

Constructor Summary

Constructors

Constructor and Description
MonitoredReadStream(org.vertx.java.core.streams.ReadStream<?> stream, BMExecutor.BMTaskMonitor monitor)

Method Summary

Modifier and Type	Method and Description
MonitoredReadStream	dataHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> handler)
MonitoredReadStream	endHandler(org.vertx.java.core.Handler<java.lang.Void> endHandler)
MonitoredReadStream	exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> handler)
MonitoredReadStream	pause()
MonitoredReadStream	resume()

Methods inherited from class java.lang.Object

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

Constructor Detail

MonitoredReadStream

public MonitoredReadStream(org.vertx.java.core.streams.ReadStream<?> stream,
                           BMExecutor.BMTaskMonitor monitor)

Method Detail

dataHandler

public MonitoredReadStream dataHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> handler)

Specified by:

dataHandler in interface org.vertx.java.core.streams.ReadSupport<MonitoredReadStream,org.vertx.java.core.buffer.Buffer>

pause

public MonitoredReadStream pause()

Specified by:

pause in interface org.vertx.java.core.streams.ReadSupport<MonitoredReadStream,org.vertx.java.core.buffer.Buffer>

resume

public MonitoredReadStream resume()

Specified by:

resume in interface org.vertx.java.core.streams.ReadSupport<MonitoredReadStream,org.vertx.java.core.buffer.Buffer>

exceptionHandler

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

Specified by:

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

endHandler

public MonitoredReadStream endHandler(org.vertx.java.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface org.vertx.java.core.streams.ReadStream<MonitoredReadStream>