-
Notifications
You must be signed in to change notification settings - Fork 7.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add zip(iterable, selector) to RxScala #1247
Conversation
…ndex; update CompletenessTest.scala
RxJava-pull-requests #1147 SUCCESS |
For zipping with an Observable, we have def zip[U](that: Observable[U]): Observable[(T, U)]
def zipWith[U, R](that: Observable[U], selector: (T,U) => R): Observable[R] So to be consistent, the signatures for zipping with an Iterable should be: def zip[U](that: Iterable[U]): Observable[(T, U)]
def zipWith[U, R](that: Iterable[U], selector: (T,U) => R): Observable[R] |
And you could add a good and bad example to RxScalaDemo: Bad zips an Observable.interval with an infinite Observable (and thus the same happens as with the previous zip version), and good zips Observable.interval with an infinite Iterable. |
Agreed. |
I'll wait until a go ahead to merge this as it seems there are additions to make. |
Already updated. |
RxJava-pull-requests #1151 SUCCESS |
We should wait with this until #1253 is fixed. |
Is this now ready to merge since #1253 is merged? |
Yes, it delegates to the Java one. |
Merge pull request #1247
zip(iterable, selector)
to RxScalazip(iterable, selector)
to reimplementzipWithIndex
to resolve the issue mentioned in Fix bug inzipWithIndex
and setzip(that, selector)
public in RxScala #1226/cc @samuelgruetter