| Package | Description |
|---|---|
| io.vertx.core.streams | |
| io.vertx.reactivex.core.streams | |
| io.vertx.rxjava.core.streams | |
| io.vertx.rxjava3.core.streams |
| 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) |
| 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 © 2023 Eclipse. All rights reserved.