Source Code for 'Reactive Streams in Java' by Adam L. Davis - View it on GitHub