-
Notifications
You must be signed in to change notification settings - Fork 184
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 Single.zipWith and Single.zip operators #1431
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
That came together pretty quickly!
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/SingleZipper.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/SingleZipper.java
Outdated
Show resolved
Hide resolved
build failure attributed to #999 |
build failure attributed to #1192 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Some suggestions then lgtm
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Function4.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Function4.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/Single.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/SingleZipper.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/SingleZip5Test.java
Outdated
Show resolved
Hide resolved
servicetalk-concurrent-api/src/main/java/io/servicetalk/concurrent/api/SingleZipper.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚀 🚀 Awesome work!
Motivation: Executing multiple async operations in parallel and combining them in a type safe way is a common use case, and referred to as zip [1]. We do not support a zip operator which requires a careful sequence of operators to replicate. [1] http://reactivex.io/documentation/operators/zip.html Modifications: - Add Single.zipWith - Add Single.zip overload for 3, 4, and varargs amount of Singles Result: Single.zip and Single.zipWith operators exist.
Motivation: Executing multiple async operations in parallel and combining them in a type safe way is a common use case, and referred to as zip [1]. We do not support a zip operator which requires a careful sequence of operators to replicate. [1] http://reactivex.io/documentation/operators/zip.html Modifications: - Add Single.zipWith - Add Single.zip overload for 3, 4, and varargs amount of Singles Result: Single.zip and Single.zipWith operators exist.
Motivation:
Executing multiple async operations in parallel and combining them in a
type safe way is a common use case, and referred to as zip [1]. We do
not support a zip operator which requires a careful sequence of
operators to replicate.
[1] http://reactivex.io/documentation/operators/zip.html
Modifications:
Result:
Single.zip and Single.zipWith operators exist.