In short, we can have three level 1 policies:
unbounded
overflow - the current impl
backpressure - with a level 2 policy to drop the new message or block until the slowest receivers move forward
Option 1 requires an unlimited growable buffer and properly drops the head when the last receiver moves forward.
Option 3 requires the sender to know whether there is any receiver awaiting, and perhaps the sender needs to await and being waken up.
Originally posted by @tisonkun in #88
Originally posted by @tisonkun in #88