Package net.bluemind.core.rest.http.internal

Class BufferedStream

java.lang.Object

net.bluemind.core.rest.http.internal.BufferedStream

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor	Description
BufferedStream()

Method Summary

Modifier and Type	Method	Description
void	end()
BufferedStream	endHandler(io.vertx.core.Handler<Void> endHandler)
BufferedStream	exceptionHandler(io.vertx.core.Handler<Throwable> handler)
void	failure(Throwable t)
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long amount)
BufferedStream	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
BufferedStream	pause()
BufferedStream	resume()
void	write(io.vertx.core.buffer.Buffer data)

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

BufferedStream

public BufferedStream()

Method Details

handler

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

Specified by:

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

resume

public BufferedStream resume()

Specified by:

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

exceptionHandler

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

Specified by:

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

write

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

failure

public void failure(Throwable t)

end

public void end()

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>