Tweaked DelegatingConsumer javadoc to explain that Consumer references are weak.
Made Processor a Supplier<Operation<T>>
Added Pipe helper to connect Suppliers to Consumers. Using the new helper methods on the Suppliers class, it's possible to aggregate Suppliers of various single-threaded Queues into a common Consumer, which can in turn be used to supply events to a Processor or other Reactor component.
Tweak to the TcpClientTests to make sure the AbortServer was properly cleaned up after each test.