-
-
Notifications
You must be signed in to change notification settings - Fork 187
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
Backpressure #87
Comments
Was just about to open this issue, glad to see it already here 👍 |
Not at the moment, but I can see how that would be useful. It shouldn't be hard to add a |
Currently I achieve some sort of backpressure using this library with the onEmpty promise |
Actually since |
A function has been added |
When using |
|
These libraries are awesome and make building consistent asynchronous code much easier.
But, is there a mechanism in this library or one of the other p-libraries to have a queue-like data structure like this that implements some type of back-pressure so that if a queue gets to a certain size, the function calling the add() method will pause until the queue size has reduced?
The text was updated successfully, but these errors were encountered: