Handles a RUN/PULL_ALL, or RUN/DISCARD_ALL requests, maps the responses in a way that a user-provided observer can see these as a clean Stream of records. This class will queue up incoming messages until a user-provided observer for the incoming stream is registered. Thus, we keep fields around for tracking head/records/tail. These are only used if there is no observer registered.