@ Override public Streamlet < R > filter ( SerializablePredicate < R > filterFn ) { checkNotNull ( filterFn , "filterFn cannot be null" ) ; FilterStreamlet < R > retval = new FilterStreamlet <> ( this , filterFn ) ; addChild ( retval ) ; return retval ; }
Return a new Streamlet by applying the filterFn on each element of this streamlet and including only those elements that satisfy the filterFn