EventSubscriber provides a quasi-streaming API on top of EventBuffer, but a lot of is usage is essentially reimplementing EventBuffer.  We should remove usage of EventSubscriber in favor of EventBuffer, using the watch_all method where async notification is really needed.