Package net.bluemind.core.rest.utils

Class InputReadStream

java.lang.Object

net.bluemind.core.rest.utils.InputReadStream

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Constructor	Description
InputReadStream(InputStream in)

Method Summary

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

InputReadStream

public InputReadStream(InputStream in)

Method Details

handler

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

Specified by:

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

resume

public InputReadStream resume()

Specified by:

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

exceptionHandler

public InputReadStream 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 InputReadStream 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>