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

Feature request:Add Sink.exists operator #973

Closed
He-Pin opened this issue Jan 17, 2024 · 2 comments · Fixed by #990
Closed

Feature request:Add Sink.exists operator #973

He-Pin opened this issue Jan 17, 2024 · 2 comments · Fixed by #990
Labels
t:stream Pekko Streams
Milestone
1.1.0-M1

Comments

@He-Pin
Copy link
Member

He-Pin commented Jan 17, 2024 •
edited
Loading

Motivation:
Add Sink.exists operator ,which can be implemented with Sink.fold / statefulMap.
Both zio and fs2 has this mehtod.

Result:
Rich operators set.

It should work as Java Stream's anyMatch.
@He-Pin He-Pin changed the title Feature request:Add Sink.exists operator Feature request:Add Sink/Flow.exists operator Jan 17, 2024
@He-Pin He-Pin added the t:stream Pekko Streams label Jan 17, 2024
@He-Pin
Copy link
Member Author

He-Pin commented Jan 17, 2024

@GreyPlane Would you like to take care about this?

@He-Pin He-Pin added this to the 1.1.0 milestone Jan 17, 2024
@GreyPlane
Copy link
Contributor

Thanks for the mention, I think it's OK, I'd like to pick this up maybe this weekend or earlier If I had time.

@GreyPlane GreyPlane mentioned this issue Jan 20, 2024
Merged
@He-Pin He-Pin changed the title Feature request:Add Sink/Flow.exists operator Feature request:Add Sink.exists operator Jan 28, 2024
@He-Pin He-Pin linked a pull request Jan 29, 2024 that will close this issue
feat: Add Sink.exists operator #990
Merged
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
t:stream Pekko Streams
Projects
None yet
Milestone
1.1.0-M1
Development

Successfully merging a pull request may close this issue.

feat: Add Sink.exists operator GreyPlane/incubator-pekko
2 participants
@He-Pin @GreyPlane