Contents

require 'celluloid'

class Eye::Utils::CelluloidChain
  include Celluloid

  def initialize(target)
    @target = target
    @calls = []
    @running = false
  end

  def add(method_name, *args, &block)
    @calls << {:method_name => method_name, :args => args, :block => block}
    ensure_process
  end

  def add_wo_dups(method_name, *args, &block)
    h = {:method_name => method_name, :args => args, :block => block}
    if @calls[-1] != h
      @calls << h
      ensure_process
    end
  end

  def add_wo_dups_current(method_name, *args, &block)
    h = {:method_name => method_name, :args => args, :block => block}
    if !@calls.include?(h) && @call != h
      @calls << h
      ensure_process
    end
  end

  def list
    @calls
  end

  def names_list
    list.map{|el| el[:method_name].to_sym }
  end

  def clear
    @calls = []
  end

  alias :clear_pending_list :clear

  # need, because of https://github.com/celluloid/celluloid/issues/22
  def inspect
    "Celluloid::Chain(#{@target.class}: #{@calls.inspect})"
  end

  attr_reader :running

private

  def ensure_process
    unless @running
      @running = true
      async.process
    end
  end

  def process
    while @call = @calls.shift
      @running = true
      @target.send(@call[:method_name], *@call[:args], &@call[:block]) if @target.alive?
    end
    @running = false
  end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
reel-eye-0.4	lib/eye/utils/celluloid_chain.rb
eye-0.4	lib/eye/utils/celluloid_chain.rb
reel-eye-0.3.2	lib/eye/utils/celluloid_chain.rb
eye-0.3.2	lib/eye/utils/celluloid_chain.rb
reel-eye-0.3.1	lib/eye/utils/celluloid_chain.rb
eye-0.3.1	lib/eye/utils/celluloid_chain.rb