Error Handling in Asynchronous Streams

Implement robust error propagation patterns that respect the Future polling lifecycle.