class Plumb::StreamClass

def filtered

Returns:
  • (Step) - a step that resolves to an Enumerator that filters out invalid elements 
def filtered
  self >> Step.new(nil, 'filtered') do |result|
    set = result.value.lazy.filter_map { |e| e.value if e.valid? }
    result.valid(set)
  end
end