Hack pipeline

Rough draft of the real-time pipelines.
What would the purpose of the `None` return be?  I was under the impression that there would always be some sort of aggregator at the end of an analysis pipeline.  Visualization would then be hooked into an aggregator, or something along those lines.