@ Override public void consume ( SerializableConsumer < R > consumer ) { checkNotNull ( consumer , "consumer cannot be null" ) ; ConsumerStreamlet < R > consumerStreamlet = new ConsumerStreamlet <> ( this , consumer ) ; addChild ( consumerStreamlet ) ; }
Applies the consumer function for every element of this streamlet