@ Override public void toSink ( Sink < R > sink ) { checkNotNull ( sink , "sink cannot be null" ) ; SinkStreamlet < R > sinkStreamlet = new SinkStreamlet <> ( this , sink ) ; addChild ( sinkStreamlet ) ; }
Uses the sink to consume every element of this streamlet