Consume stream returned from task

Fixes #48: Consume streams returned by tasks, to relieve
back pressure and allow stream to be fully processed.

Please see [my comment on issue #48](https://github.com/orchestrator/orchestrator/issues/48#issuecomment-49500707) for further detail.