Sha256: be8179021fb6ec384428ebd7016298fd641cbdb92a69b8b31ccf88d83b0f821f

Contents?: true

Size: 1.62 KB

Versions: 1

Compression:

Stored size: 1.62 KB

Contents

require_relative 'spec_helper'


module Mikka
  class TestActor < Mikka::Actor
    def receive(msg)
      sender << msg
    end
  end

  describe 'actor creation' do
    before do
      @system = Mikka.create_actor_system('testsystem')
    end

    after do
      @system.shutdown
    end

    it 'creates an actor from a class' do
      actor_props = Props[TestActor]
      actor = @system.actor_of(actor_props, 'some_actor')
      actor.should be_a(ActorRef)
    end

    it 'creates an actor from a factory proc' do
      actor_props = Props[:creator => proc { TestActor.new }]
      actor = @system.actor_of(actor_props, 'some_actor')
      actor.should be_a(ActorRef)
    end

    it 'creates an actor from a factory block' do
      actor_props = Props.create { TestActor.new }
      actor = @system.actor_of(actor_props, 'some_actor')
      actor.should be_a(ActorRef)
    end

    it 'creates an actor from a factory block passed to the Props function' do
      actor_props = Useful.Props { TestActor.new }
      actor = @system.actor_of(actor_props, 'some_actor')
      actor.should be_a(ActorRef)
    end
  end

  describe 'message sending' do
    before do
      @system = Mikka.create_actor_system('testsystem')
      @actor = @system.actor_of(Props[TestActor])
    end

    after do
      @system.shutdown
    end

    describe '#tell/#<<' do
      it 'sends a message to an actor' do
        @actor << 'hello'
      end
    end

    describe '#ask' do
      it 'sends a message'
            # future = actor.ask(:hi, 1000)
      # reply = Mikka.await_result(future, :timeout => '1000ms')
      # reply.should == :hi

      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
mikka-2.0.0.pre1-java spec/mikka_spec.rb