A golang package to help queue up, consume entries from a pipeline, return results and stop consuming as required.
