| Package | Description |
|---|---|
| dev.snowdrop.vertx.streams |
| Modifier and Type | Method and Description |
|---|---|
WriteStream<T> |
WriteStream.drainHandler(Consumer<Void> handler) |
WriteStream<T> |
WriteStream.exceptionHandler(Consumer<Throwable> handler) |
WriteStream<T> |
WriteStream.setWriteQueueMaxSize(int maxSize) |
| Modifier and Type | Method and Description |
|---|---|
default reactor.core.publisher.Mono<Void> |
ReadStream.pipeTo(WriteStream<T> destination) |
static <T> Pump |
Pump.pump(ReadStream<T> readStream,
WriteStream<T> writeStream) |
static <T> Pump |
Pump.pump(ReadStream<T> readStream,
WriteStream<T> writeStream,
int writeQueueMaxSize) |
reactor.core.publisher.Mono<Void> |
Pipe.to(WriteStream<T> destination) |
Copyright © 2020. All rights reserved.