module Concurrent::Stream


Influenced by Ruby parallel and Java streams.

Creating a stream:

Stream operations:

Final results and error handling

All method chains should end with #wait, #serial, or #to_a all of which gather errors and end parallel processing. You may omit calling #wait when using #run for background tasks where completion is not guaranteed. When used in this fashion make sure to catch all exceptions in the run block or the internal exception channel may fill. causing the entire pipeline to stop.

Error handling

Use #wait, #serial, or #to_a receive errors or rescue within any blocks. Better handling is a WIP.


Defined in:


Constant Summary

Log = ::Log.for(self)