Package net.bluemind.core.rest.vertx

Class BufferReadStream

java.lang.Object

net.bluemind.core.rest.vertx.BufferReadStream

All Implemented Interfaces:

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

public class BufferReadStream
extends Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

Constructor Summary

Constructors

Constructor	Description
BufferReadStream(io.vertx.core.buffer.Buffer data)

Method Summary

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

BufferReadStream

public BufferReadStream(io.vertx.core.buffer.Buffer data)

Method Details

nettyBuffer

public io.netty.buffer.ByteBuf nettyBuffer()

handler

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

Specified by:

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

resume

public BufferReadStream resume()

Specified by:

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

exceptionHandler

public BufferReadStream 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 BufferReadStream endHandler(io.vertx.core.Handler<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>