net.bluemind.core.rest.vertx

Class VertxStreamConsumer

java.lang.Object

net.bluemind.core.rest.vertx.VertxStreamConsumer

All Implemented Interfaces:

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

public class VertxStreamConsumer
extends java.lang.Object
implements org.vertx.java.core.streams.ReadStream<VertxStreamConsumer>, Stream

Constructor Summary

Constructors

Constructor and Description
VertxStreamConsumer(org.vertx.java.core.Vertx vertx, java.lang.String streamAddress)

Method Summary

Modifier and Type	Method and Description
VertxStreamConsumer	dataHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> handler)
VertxStreamConsumer	endHandler(org.vertx.java.core.Handler<java.lang.Void> endHandler)
VertxStreamConsumer	exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> handler)
void	fail(java.lang.Throwable e)
VertxStreamConsumer	pause()
void	pushData(org.vertx.java.core.buffer.Buffer data)
void	pushEnd()
VertxStreamConsumer	resume()

Methods inherited from class java.lang.Object

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

Constructor Detail

VertxStreamConsumer

public VertxStreamConsumer(org.vertx.java.core.Vertx vertx,
                           java.lang.String streamAddress)

Method Detail

dataHandler

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

Specified by:

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

pause

public VertxStreamConsumer pause()

Specified by:

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

resume

public VertxStreamConsumer resume()

Specified by:

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

exceptionHandler

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

Specified by:

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

endHandler

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

Specified by:

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

pushData

public void pushData(org.vertx.java.core.buffer.Buffer data)

pushEnd

public void pushEnd()

fail

public void fail(java.lang.Throwable e)