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 |