Clean up reader reading.
Refactor indexer pool into generic work queue service.
Rewrite stream queue with worker api.
Wip.
Wip.