This library implements a minimal framework for handling an ordered queue of tasks that is both suitable for stream and batch processing.