join: include from stream's pipeline in _pipeline
reporter: add one reporter per entire pipeline to ensure interval is cleared

If you add a separate reporter to each pipeline segment, if an error is emitted
from a stream, only the segment with that stream will clear its reporter.