RxKotlin icon indicating copy to clipboard operation
RxKotlin copied to clipboard

Add Flowables.combineLatest() and Flowables.zip() with additional parameters (3.x)

Open SpaceBison opened this issue 4 years ago • 0 comments

This PR adds new functions to Flowables :

  • Flowables.combineLatest variants that take bufferSize parameter
  • Flowables.zip variants that take delayError and bufferSize parameters

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 }

SpaceBison avatar Dec 29 '21 22:12 SpaceBison