0no-co / wonka

🎩 A tiny but capable push & pull stream library for TypeScript and Flow
MIT License
709 stars 29 forks source link

Add backpressure operators #62

Closed kitten closed 2 years ago

kitten commented 4 years ago

There are certain cases where sinks don't consume push signals as fast as they're sent. This can often happen with an asynchronous source that is fed through a delay or an asynchronous sink.

In such cases currently you can only use debounce or throttle (maybe even buffer) but it'd be nice to have actual backpressure operators.

Such operators would not let new values through while no Pull event has come back.