class Lalka::Internal

Public Class Methods

new(queue) click to toggle source
# File lib/lalka.rb, line 211
def initialize(queue)
  @queue = queue
end

Public Instance Methods

reject(error) click to toggle source
# File lib/lalka.rb, line 224
def reject(error)
  result =
    if @on_error.nil?
      ArgumentError.new('missing on_error block')
    else
      @on_error.call(error)
    end

  @queue.push M.Left(result)
end
resolve(value) click to toggle source
# File lib/lalka.rb, line 215
def resolve(value)
  if @on_success.nil?
    reject(ArgumentError.new('missing on_success block'))
  else
    result = @on_success.call(value)
    @queue.push M.Right(result)
  end
end