net.bluemind.todolist.service.internal

Class GenericObjectStream<T>

java.lang.Object

net.bluemind.todolist.service.internal.GenericObjectStream<T>

All Implemented Interfaces:

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

public abstract class GenericObjectStream<T>
extends java.lang.Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

Constructor Summary

Constructors

Constructor and Description
GenericObjectStream()

Method Summary

Modifier and Type	Method and Description
GenericObjectStream<T>	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
GenericObjectStream<T>	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> exceptionHandler)
GenericObjectStream<T>	fetch(long amount)
GenericObjectStream<T>	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> dataHandler)
protected abstract T	next()
GenericObjectStream<T>	pause()
GenericObjectStream<T>	resume()
protected abstract io.vertx.core.buffer.Buffer	serialize(T n)

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 Detail

GenericObjectStream

public GenericObjectStream()

Method Detail

handler

public GenericObjectStream<T> handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> dataHandler)

Specified by:

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

pause

public GenericObjectStream<T> pause()

Specified by:

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

resume

public GenericObjectStream<T> resume()

Specified by:

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

exceptionHandler

public GenericObjectStream<T> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> exceptionHandler)

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 GenericObjectStream<T> endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)

Specified by:

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

serialize

protected abstract io.vertx.core.buffer.Buffer serialize(T n)
                                                  throws java.lang.Exception

Throws:

java.lang.Exception

next

protected abstract T next()
                   throws java.lang.Exception

Throws:

java.lang.Exception

fetch

public GenericObjectStream<T> fetch(long amount)

Specified by:

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