populate fusion logger into context

add tests for runner

Refactor fusion to use a composition model

Use bufio reader to in linestream for large files

Make fusion single proc stage

Rename Message, change Proc to be a function type

Fix early worker exit, line-stream size issue

Remove stages argument

Fix off-by-one issue in line stream offset

Add line counter example