Refactor the Engine to use async interators

[inverted-capital]

Currently uses bespoke queues and awaits, but this could be simplified if streaming iterables were used throughout.

The Engine should be a connection of streaming iterables for control flow only, with all functions in separate files.