| Package | Description | 
|---|---|
| io.vertx.core.spi | |
| io.vertx.core.streams | |
| io.vertx.reactivex.core.streams | |
| io.vertx.rxjava.core.streams | 
| Modifier and Type | Method and Description | 
|---|---|
<T> Pump | 
PumpFactory.pump(ReadStream<T> rs,
    WriteStream<T> ws)  | 
<T> Pump | 
PumpFactory.pump(ReadStream<T> rs,
    WriteStream<T> ws,
    int writeQueueMaxSize)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> Pump | 
Pump.pump(ReadStream<T> rs,
    WriteStream<T> ws)
Create a new  
Pump with the given ReadStream and WriteStream | 
static <T> Pump | 
Pump.pump(ReadStream<T> rs,
    WriteStream<T> ws,
    int writeQueueMaxSize)
Create a new  
Pump with the given ReadStream and WriteStream and
 writeQueueMaxSize | 
Pump | 
Pump.setWriteQueueMaxSize(int maxSize)
Set the write queue max size to  
maxSize | 
Pump | 
Pump.start()
Start the Pump. 
 | 
Pump | 
Pump.stop()
Stop the Pump. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Pump | 
Pump.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static Pump | 
Pump.newInstance(Pump arg)  | 
| Constructor and Description | 
|---|
Pump(Pump delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
Pump | 
Pump.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static Pump | 
Pump.newInstance(Pump arg)  | 
| Constructor and Description | 
|---|
Pump(Pump delegate)  | 
Copyright © 2020 Eclipse. All rights reserved.