Contents

require 'mutant/actor'

# A fake actor used from specs
module FakeActor
  class Expectation
    include Concord::Public.new(:name, :message)
  end

  class MessageSequence
    include Adamantium::Flat, Concord.new(:messages)

    def self.new
      super([])
    end

    def add(name, *message_arguments)
      messages << Expectation.new(name, Mutant::Actor::Message.new(*message_arguments))
      self
    end

    def sending(expectation)
      raise "Unexpected send: #{expectation.inspect}" if messages.empty?
      expected = messages.shift
      unless expectation.eql?(expected)
        raise "Got:\n#{expectation.inspect}\nExpected:\n#{expected.inspect}"
      end
      self
    end

    def receiving(name)
      raise "No message to read for #{name.inspect}" if messages.empty?
      expected = messages.shift
      raise "Unexpected message #{expected.inspect} for #{name.inspect}" unless expected.name.eql?(name)
      expected.message
    end

    def consumed?
      messages.empty?
    end
  end

  class Env
    include Concord.new(:messages, :actor_names)

    def spawn
      name = @actor_names.shift
      raise 'Tried to spawn actor when no name available' unless name
      actor = actor(name)
      yield actor if block_given?
      actor.sender
    end

    def current
      actor(:current)
    end

    def actor(name)
      Actor.new(name, @messages)
    end
  end # Env

  class Actor
    include Concord.new(:name, :messages)

    def receiver
      Receiver.new(name, messages)
    end

    def sender
      Sender.new(name, messages)
    end

    def bind(sender)
      Mutant::Actor::Binding.new(self, sender)
    end
  end

  class Sender
    include Concord.new(:name, :messages)

    def call(message)
      messages.sending(Expectation.new(name, message))
    end
  end # Sender

  class Receiver
    include Concord::Public.new(:name, :messages)

    def call
      messages.receiving(name)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
mutant-0.7.1	spec/support/fake_actor.rb