Extract stream and consumer monitoring into package

[ripienaar]

This allows the CLI and other tools to share logic and yield identical results

Signed-off-by: R.I.Pienaar rip@devco.net