module Ravengar

# File lib/ravengar/engine/source_wrapper.rb, line 46
def abort!
  throw :abort_proc
end

# File lib/ravengar/base_library.rb, line 22
def diffuser(*lambds)
  diffus = lambds.cycle
  ->(*args) do
    diffus.next.call(*args)
  end
end

# File lib/ravengar/base_library.rb, line 7
def filter(lambd)
  ->(it) do
    value = lambd.call(it)
    if value
      it
    else
      skip!
    end
  end
end

# File lib/ravengar/base_library.rb, line 17
def replicator(*lambds)
  ->(it) do
    lambds.map { |lambd| lambd.call(it) }
  end
end

# File lib/ravengar/base_library.rb, line 4
def show(output = $stdout, separator: "\n")
  ->(it) { output << it.inspect << separator; it }
end

# File lib/ravengar/engine/source_wrapper.rb, line 43
def skip!
  throw :skip_proc
end

# File lib/ravengar/array.rb, line 5
def |(lambd)
  Ravengar::SourceWrapper.new(self) | lambd
end