Fix operators that may stall when cold sources aren't receiving Pull signals

0no-co / wonka

🎩 A tiny but capable push & pull stream library for TypeScript and Flow

MIT License

709 stars 29 forks source link

Fix operators that may stall when cold sources aren't receiving Pull signals #60

Closed kitten closed 4 years ago

kitten commented 4 years ago

Some operators omit Push signals until an appropriate time to send them and also have inner sources that are being pulled at the same time.

This can cause a condition where cold sources aren't being pulled anymore as the sink is not receiving a value that it can react to with a Pull signal.