Class VertxStream

java.lang.Object

net.bluemind.core.rest.vertx.VertxStream

public class VertxStream
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	VertxStream.LocalPathStream
static class	VertxStream.ReadStreamStream

Method Summary

Modifier and Type	Method	Description
static Stream	localPath(Path p)
static <T> io.vertx.core.streams.ReadStream<T>	read(Stream stream)	After using this method, you need to setup handlers for the stream, then resume() the stream to start processing data
static CompletableFuture<Void>	sink(Stream stream)
static Stream	stream(io.vertx.core.buffer.Buffer body)
static Stream	stream(io.vertx.core.buffer.Buffer body, String mime, String charset)
static Stream	stream(io.vertx.core.buffer.Buffer body, String mime, String charset, String fileName)
static Stream	stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream)
static Stream	stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream, io.vertx.core.Handler<Void> hook)
static Stream	stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream, String mime)
static Stream	stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream, String mime, String charset)
static Stream	stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream, String mime, String charset, String fileName)

Methods inherited from class Object

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

Method Details

stream

public static Stream stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream)

stream

public static Stream stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream,
 io.vertx.core.Handler<Void> hook)

stream

public static Stream stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream,
 String mime)

stream

public static Stream stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream,
 String mime,
 String charset)

stream

public static Stream stream(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream,
 String mime,
 String charset,
 String fileName)

read

public static <T>
io.vertx.core.streams.ReadStream<T> read(Stream stream)

After using this method, you need to setup handlers for the stream, then resume() the stream to start processing data

Type Parameters:

T -

Parameters:

stream - Bluemind wrapper object Stream

Returns:

a Vert.x ReadStream

sink

public static CompletableFuture<Void> sink(Stream stream)

localPath

public static Stream localPath(Path p)

stream

public static Stream stream(io.vertx.core.buffer.Buffer body,
 String mime,
 String charset)

stream

public static Stream stream(io.vertx.core.buffer.Buffer body,
 String mime,
 String charset,
 String fileName)

stream

public static Stream stream(io.vertx.core.buffer.Buffer body)