Package | Description |
---|---|
io.vertx.reactivex.core.streams |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<Pump> |
Pump.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static Pump |
Pump.newInstance(Pump arg) |
static <T> Pump |
Pump.pump(Flowable<T> rs,
WriteStream<T> ws)
Deprecated.
|
static <T> Pump |
Pump.pump(Flowable<T> rs,
WriteStream<T> ws,
int writeQueueMaxSize)
Deprecated.
|
static <T> Pump |
Pump.pump(ReadStream<T> rs,
WriteStream<T> ws)
Deprecated.
|
static <T> Pump |
Pump.pump(ReadStream<T> rs,
WriteStream<T> ws,
int writeQueueMaxSize)
Deprecated.
|
Pump |
Pump.setWriteQueueMaxSize(int maxSize)
Deprecated.
|
Pump |
Pump.start()
Deprecated.
|
Pump |
Pump.stop()
Deprecated.
|
Copyright © 2024 Eclipse. All rights reserved.