Uses of Class
io.vertx.reactivex.core.streams.Pump

Packages that use Pump

Package	Description
io.vertx.reactivex.core.streams

Uses of Pump in io.vertx.reactivex.core.streams

Fields in io.vertx.reactivex.core.streams with type parameters of type Pump

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<Pump>	Pump.__TYPE_ARG

Methods in io.vertx.reactivex.core.streams that return Pump

Modifier and Type	Method and Description
static Pump	Pump.newInstance(Pump arg)
static <T> Pump	Pump.pump(Flowable<T> rs, WriteStream<T> ws) Create a new Pump with the given ReadStream and WriteStream
static <T> Pump	Pump.pump(Flowable<T> rs, WriteStream<T> ws, int writeQueueMaxSize) Create a new Pump with the given ReadStream and WriteStream and writeQueueMaxSize
static <T> Pump	Pump.pump(Observable<T> rs, WriteStream<T> ws) Create a new Pump with the given ReadStream and WriteStream
static <T> Pump	Pump.pump(Observable<T> rs, WriteStream<T> ws, int writeQueueMaxSize) Create a new Pump with the given ReadStream and WriteStream and writeQueueMaxSize
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.