Handling Failures in Asynchronous Streams

Propagate errors through async stream pipelines using pinned result types.