vertx / io.vertx.rxjava.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: 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: 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