Consume stream returned from task

Fixes #48: Consume streams returned by tasks, to relieve
back pressure and allow stream to be fully processed.