I reemit the error because otherwise the domain in `.run()` doesn't catch it. I guess domains only catch unhandled errors?

When there is an error in the pipeline, does each stream emit it? I thought just one stream would emit it, so we needed a handler on each.