Skip to content
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.

Sign up for GitHub

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

Jump to bottom

Stream: interop java.util.concurrent.Flow Reactive Stream #881

Open
calvinlfer opened this issue Nov 30, 2024 · 0 comments
Open

Stream: interop java.util.concurrent.Flow Reactive Stream #881

calvinlfer opened this issue Nov 30, 2024 · 0 comments
Labels
new API

Comments

@calvinlfer
Copy link
Contributor

Implement support to interop with java.util.concurrent.Flow's Publisher/Subscriber/Subscription to and from Kyo effects

This is a follow-up to #679

For example, see how FS2 Streams does it
@calvinlfer calvinlfer changed the title Implement reactive streams interop for Kyo Feature request: Implement reactive streams interop for Kyo Nov 30, 2024
@hearnadam hearnadam changed the title Feature request: Implement reactive streams interop for Kyo Stream: interop java.util.concurrent.Flow Reactive Stream Dec 3, 2024
This was referenced Dec 3, 2024
Draft
Merged
fwbrasil pushed a commit that referenced this issue Dec 17, 2024
@HollandDM
Reactive-stream/Flow Interop (#896)
702fbdc 
Originally, this was created just to resolve #764, but since #881 was
requested, I took sometime to create a dedicated PR for it.
This took both ZIO's and Fs2's approaches as the inspiration, and passes
the
[reactive-stream-tck](https://github.com/reactive-streams/reactive-streams-jvm/tree/master/tck-flow)
testcases. I also add some test cases derived from Fs2's codebase.
Hopefully it covers enough.
With this, solving #764 will be more trivial.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
new API
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@calvinlfer @hearnadam