Package net.bluemind.core.rest.vertx

Class VertxStreamConsumer

java.lang.Object

net.bluemind.core.rest.vertx.VertxStreamConsumer

All Implemented Interfaces:

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

public class VertxStreamConsumer
extends Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, Stream

Constructor Summary

Constructors

Constructor	Description
VertxStreamConsumer(io.vertx.core.Vertx vertx, String streamAddress)

Method Summary

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

Methods inherited from interface io.vertx.core.streams.ReadStream

pipe, pipeTo, pipeTo

Methods inherited from interface net.bluemind.core.api.Stream

charset, fileName, mime

Constructor Details

VertxStreamConsumer

public VertxStreamConsumer(io.vertx.core.Vertx vertx,
 String streamAddress)

Method Details

handler

public VertxStreamConsumer 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 VertxStreamConsumer pause()

Specified by:

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

resume

public VertxStreamConsumer resume()

Specified by:

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

exceptionHandler

public VertxStreamConsumer exceptionHandler(io.vertx.core.Handler<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 VertxStreamConsumer endHandler(io.vertx.core.Handler<Void> endHandler)

Specified by:

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

pushData

public void pushData(io.vertx.core.buffer.Buffer data)

pushEnd

public void pushEnd()

fail

public void fail(Throwable e)

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>