async: use Async pipes to return FETCH results
Cleanup. Fix typo
lwt: close stream on FETCH errors
async: close writer on FETCH errors