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.

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 Observable.throttle #958

Merged
merged 1 commit into from Jul 24, 2019

Conversation

@Avasil
Copy link
Collaborator

commented Jul 24, 2019

I'm not aware of equivalent in ReactiveX but it's quite handy operator and bufferTimedWithPressure is confusing and hard to find

It's called throttle in Akka Streams: https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/throttle.html

And metered in fs2

@Avasil Avasil requested review from alexandru and oleg-py Jul 24, 2019

@oleg-py
Copy link
Collaborator

left a comment

I never actually felt the need for this myself neither in monix nor in fs2, but bufferTimedWithPressure is truly hard to find 😄

@Avasil Avasil merged commit f337ebe into monix:master Jul 24, 2019

1 check passed

continuous-integration/travis-ci/pr The Travis CI build passed
Details

@Avasil Avasil deleted the Avasil:obs-throttle branch Aug 21, 2019

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
2 participants
You can’t perform that action at this time.