Stream is a generic implementation for concurrency communication patterns - View it on GitHub