Basic tracking of active real time streams and pending historical
requests in the client. Needs more work.