net.bluemind.core.rest.base

Class GenericStream<T>

java.lang.Object

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

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
GenericStream()

Method Summary

Modifier and Type	Method and Description
static <T> java.util.concurrent.CompletableFuture<io.vertx.core.buffer.Buffer>	asyncStreamToBuffer(Stream stream)
GenericStream<T>	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
GenericStream<T>	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> exceptionHandler)
GenericStream<T>	fetch(long amount)
GenericStream<T>	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> dataHandler)
protected abstract GenericStream.StreamState<T>	next()
GenericStream<T>	pause()
GenericStream<T>	resume()
protected abstract io.vertx.core.buffer.Buffer	serialize(T n)
static <T> Stream	simpleValue(T value, java.util.function.Function<T,byte[]> toByteArray)
static java.util.concurrent.CompletableFuture<java.lang.Void>	slowRead(Stream stream)
static byte[]	streamToBytes(Stream stream)
static <T> void	streamToFile(Stream stream, java.io.File file)
static <T> void	streamToFile(Stream stream, java.io.File file, java.nio.file.StandardOpenOption... opts)
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

Methods inherited from interface io.vertx.core.streams.ReadStream

pipe, pipeTo, pipeTo

Constructor Detail

GenericStream

public GenericStream()

Method Detail

handler

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

fetch

public GenericStream<T> fetch(long amount)

Specified by:

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

pause

public GenericStream<T> pause()

Specified by:

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

resume

public GenericStream<T> resume()

Specified by:

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

exceptionHandler

public GenericStream<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 GenericStream<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 GenericStream.StreamState<T> next()
                                              throws java.lang.Exception

Throws:

java.lang.Exception

streamToString

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

streamToBytes

public static byte[] streamToBytes(Stream stream)

asyncStreamToBuffer

public static <T> java.util.concurrent.CompletableFuture<io.vertx.core.buffer.Buffer> asyncStreamToBuffer(Stream stream)

slowRead

public static java.util.concurrent.CompletableFuture<java.lang.Void> slowRead(Stream stream)

streamToFile

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

streamToFile

public static <T> void streamToFile(Stream stream,
                                    java.io.File file,
                                    java.nio.file.StandardOpenOption... opts)

simpleValue

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