net.bluemind.core.rest.base

Class GenericStream<T>

java.lang.Object

net.bluemind.core.rest.base.GenericStream<T>

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GenericStream.State
static class	GenericStream.StreamState<T>

Constructor Summary

Constructors

Constructor and Description
GenericStream()

Method Summary

Modifier and Type	Method and Description
GenericStream<T>	dataHandler(org.vertx.java.core.Handler<org.vertx.java.core.buffer.Buffer> dataHandler)
GenericStream<T>	endHandler(org.vertx.java.core.Handler<java.lang.Void> endHandler)
GenericStream<T>	exceptionHandler(org.vertx.java.core.Handler<java.lang.Throwable> exceptionHandler)
protected abstract GenericStream.StreamState<T>	next()
GenericStream<T>	pause()
GenericStream<T>	resume()
protected abstract org.vertx.java.core.buffer.Buffer	serialize(T n)
static <T> Stream	simpleValue(T value, java.util.function.Function<T,byte[]> toByteArray)
static void	streamToFile(Stream stream, java.io.File file)
static java.lang.String	streamToString(Stream stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericStream

public GenericStream()

Method Detail

dataHandler

public GenericStream<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<GenericStream<T>,org.vertx.java.core.buffer.Buffer>

pause

public GenericStream<T> pause()

Specified by:

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

resume

public GenericStream<T> resume()

Specified by:

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

exceptionHandler

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

Specified by:

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

endHandler

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

Specified by:

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

serialize

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

Throws:

java.lang.Exception

next

protected abstract GenericStream.StreamState<T> next()
                                              throws java.lang.Exception

Throws:

java.lang.Exception

streamToString

public static java.lang.String streamToString(Stream stream)

streamToFile

public static void streamToFile(Stream stream,
                                java.io.File file)

simpleValue

public static <T> Stream simpleValue(T value,
                                     java.util.function.Function<T,byte[]> toByteArray)