DelegatingStreamConsumer<T> constructor

DelegatingStreamConsumer<T>(StreamConsumer<T> consumer)

Create a delegating consumer forwarding calls to consumer.

Implementation 

DelegatingStreamConsumer(StreamConsumer<T> consumer) : _consumer = consumer;