Add random sleep for worker variability in tests.
Add finalizer callback and send current offset to process.
Fix unique stream arg.
Wait a bit for the logging thread to catch up when using a single worker.
Plumbing works.
Remove old code.
Thread through total stats.
WIP indexing.