vertx / io.vertx.reactivex.core.streams / Pump / pump

# pump

`open static fun <T : Any> pump(rs: ReadStream<T>, ws: WriteStream<T>): Pump`

Create a new `Pump` with the given `ReadStream` and `WriteStream`

### Parameters

`rs` - the read stream

`ws` - the write stream

Return
the pump

`open static fun <T : Any> pump(rs: Flowable<T>, ws: WriteStream<T>): Pump`
`open static fun <T : Any> pump(rs: Observable<T>, ws: WriteStream<T>): Pump`

Create a new `Pump` with the given `ReadStream` and `WriteStream`

### Parameters

`rs` - the read stream

`ws` - the write stream

Return

`open static fun <T : Any> pump(rs: ReadStream<T>, ws: WriteStream<T>, writeQueueMaxSize: Int): Pump`

Create a new `Pump` with the given `ReadStream` and `WriteStream` and `writeQueueMaxSize`

### Parameters

`rs` - the read stream

`ws` - the write stream

`writeQueueMaxSize` - the max size of the write queue

Return
the pump

`open static fun <T : Any> pump(rs: Flowable<T>, ws: WriteStream<T>, writeQueueMaxSize: Int): Pump`
`open static fun <T : Any> pump(rs: Observable<T>, ws: WriteStream<T>, writeQueueMaxSize: Int): Pump`

Create a new `Pump` with the given `ReadStream` and `WriteStream` and `writeQueueMaxSize`

### Parameters

`rs` - the read stream

`ws` - the write stream

`writeQueueMaxSize` - the max size of the write queue

Return