ideally it'd buffer some quantity of observations ...

# announcements

[mikehearn]

ideally it'd buffer some quantity of observations and then stop, so pressure builds up in the queues, which a good MQ broker can then propagate back to the observable