net.bluemind.todolist.service.internal

Class GenericObjectStream<T>

java.lang.Object

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

All Implemented Interfaces:

org.vertx.java.core.streams.ExceptionSupport<GenericObjectStream<T>>, org.vertx.java.core.streams.ReadStream<GenericObjectStream<T>>, org.vertx.java.core.streams.ReadSupport<GenericObjectStream<T>,org.vertx.java.core.buffer.Buffer>

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

Constructor Summary

Constructors

Constructor and Description
GenericObjectStream()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenericObjectStream

public GenericObjectStream()

Method Detail

dataHandler

public GenericObjectStream<T> dataHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> dataHandler)

Specified by:

dataHandler in interface org.vertx.java.core.streams.ReadSupport<GenericObjectStream<T>,org.vertx.java.core.buffer.Buffer>

pause

public GenericObjectStream<T> pause()

Specified by:

pause in interface org.vertx.java.core.streams.ReadSupport<GenericObjectStream<T>,org.vertx.java.core.buffer.Buffer>

resume

public GenericObjectStream<T> resume()

Specified by:

resume in interface org.vertx.java.core.streams.ReadSupport<GenericObjectStream<T>,org.vertx.java.core.buffer.Buffer>

exceptionHandler

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

Specified by:

exceptionHandler in interface org.vertx.java.core.streams.ExceptionSupport<GenericObjectStream<T>>

endHandler

public GenericObjectStream<T> endHandler(org.vertx.java.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface org.vertx.java.core.streams.ReadStream<GenericObjectStream<T>>

serialize

protected abstract org.vertx.java.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