module

Concurrent::Stream::ErrorHandling(E)