public interface Pump
| Modifier and Type | Method and Description |
|---|---|
int |
numberPumped() |
static <T> Pump |
pump(ReadStream<T> readStream,
WriteStream<T> writeStream) |
static <T> Pump |
pump(ReadStream<T> readStream,
WriteStream<T> writeStream,
int writeQueueMaxSize) |
Pump |
setWriteQueueMaxSize(int maxSize) |
Pump |
start() |
Pump |
stop() |
static <T> Pump pump(ReadStream<T> readStream, WriteStream<T> writeStream)
static <T> Pump pump(ReadStream<T> readStream, WriteStream<T> writeStream, int writeQueueMaxSize)
Pump setWriteQueueMaxSize(int maxSize)
Pump start()
Pump stop()
int numberPumped()
Copyright © 2020. All rights reserved.