open static fun <T : Any> pump(rs: ReadStream<T>, ws: WriteStream<T>): Pump
Create a new Pump with the given ReadStream and WriteStream
Return
the pump
open static fun <T : Any> pump(rs: Flowable<T>, ws: WriteStream<T>): Pumpopen static fun <T : Any> pump(rs: Observable<T>, ws: WriteStream<T>): Pump
Create a new Pump with the given ReadStream and WriteStream
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
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): Pumpopen 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
writeQueueMaxSize - the max size of the write queue
Return