RxKotlin
RxKotlin copied to clipboard
Add Flowables.combineLatest() and Flowables.zip() with additional parameters (3.x)
This PR adds new functions to Flowables :
-
Flowables.combineLatestvariants that takebufferSizeparameter -
Flowables.zipvariants that takedelayErrorandbufferSizeparameters
The parameters have been rearranged to make use of default parameter values and lambda syntax.
Usage example:
Flowables.combineLatest(Flowable.just(1), Flowable.just(2), bufferSize = 4) { i1, i2 -> i1 + i2 }