Class: Plumb::StreamClass

Inherits:
Object
  • Object
show all
Includes:
Composable
Defined in:
lib/plumb/stream_class.rb

Overview

A stream that validates each element. Example:

row = Types::Tuple[String, Types::Lax::Integer]
csv_stream = Types::Stream[row]

stream = csv_stream.parse(CSV.new(File.new('data.csv')).to_enum)
stream.each |result|
  result.valid? # => true
  result.value # => ['name', 10]
end

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Composable

#>>, #as_node, #build, #check, #defer, #generate, included, #invalid, #invoke, #match, #metadata, #not, #pipeline, #policy, #static, #to_json_schema, #to_s, #transform, #value, wrap, #|

Methods included from Callable

#parse, #resolve

Constructor Details

#initialize(element_type: Types::Any) ⇒ StreamClass

Returns a new instance of StreamClass.

Parameters:

  • element_type (Hash) (defaults to: Types::Any) —

    a customizable set of options

Options Hash (element_type:):

  • the (Composable) —

    type of the elements in the stream



23
24
25
26
27
 
# File 'lib/plumb/stream_class.rb', line 23

def initialize(element_type: Types::Any)
  @element_type = Composable.wrap(element_type)
  @children = [@element_type].freeze
  freeze
end

Instance Attribute Details

#children ⇒ Object (readonly)

Returns the value of attribute children.



20
21
22
 
# File 'lib/plumb/stream_class.rb', line 20

def children
  @children
end

Instance Method Details

#[](element_type) ⇒ Object

return a new Stream definition.

Parameters:

  • element_type (Composable) —

    the type of the elements in the stream



31
32
33
 
# File 'lib/plumb/stream_class.rb', line 31

def [](element_type)
  self.class.new(element_type:)
end

#call(result) ⇒ Result::Valid, Result::Invalid

The [Step] interface

Parameters:

Returns:



38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/plumb/stream_class.rb', line 38

def call(result)
  return result.invalid(errors: 'is not an Enumerable') unless result.value.respond_to?(:each)

  enum = Enumerator.new do |y|
    result.value.each do |e|
      y << @element_type.resolve(e)
    end
  end

  result.valid(enum)
end

#filtered ⇒ Step

Returns a step that resolves to an Enumerator that filters out invalid elements.

Returns:

  • (Step) —

    a step that resolves to an Enumerator that filters out invalid elements



51
52
53
54
55
56
 
# File 'lib/plumb/stream_class.rb', line 51

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