dev.snowdrop.vertx.streams

Interface ReadStream<T>

public interface ReadStream<T>

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<T>	flux()
reactor.core.publisher.Mono<T>	mono()
default Pipe<T>	pipe()
default reactor.core.publisher.Mono<Void>	pipeTo(WriteStream<T> destination)
io.vertx.core.streams.ReadStream	vertxReadStream()

Method Detail

mono

reactor.core.publisher.Mono<T> mono()

flux

reactor.core.publisher.Flux<T> flux()

pipe

default Pipe<T> pipe()

pipeTo

default reactor.core.publisher.Mono<Void> pipeTo(WriteStream<T> destination)

vertxReadStream

io.vertx.core.streams.ReadStream vertxReadStream()