Linking behavior responds to :linked message by returning array of linked actors

Author: pitr-ch

lib/concurrent/actor/behaviour/linking.rb

@@ -46,8 +46,6 @@ def initialize(core, subsequent, core_options)
           @linked.add Actor.current if core_options[:link] != false
         end
 
-        # TODO also handle :linked_actors returning array
-
         def on_envelope(envelope)
           case envelope.message
           when :link
@@ -56,6 +54,8 @@ def on_envelope(envelope)
             unlink envelope.sender
           when :linked?
             @linked.include? envelope.sender
+          when :linked
+            @linked.to_a
           else
             pass envelope
           end

spec/concurrent/actor_spec.rb

@@ -292,15 +292,15 @@ def on_message(message)
             end
 
             actor << :link
-            queue << actor.ask!(:linked?)
+            queue << actor.ask!(:linked)
             actor << nil
             queue << actor.ask(:add)
 
             -> m { queue << m }
           end
 
           expect(queue.pop).to eq :init
-          expect(queue.pop).to eq true
+          expect(queue.pop).to include(test)
           expect(queue.pop.value).to eq 1
           expect(queue.pop).to eq :resumed
           terminate_actors test
@@ -316,7 +316,7 @@ def on_message(message)
               -> m { m == :object_id ? self.object_id : pass }
             end
 
-            queue << actor.ask!(:linked?)
+            queue << actor.ask!(:linked)
             queue << actor.ask!(:object_id)
             actor << nil
             queue << actor.ask(:object_id)
@@ -327,7 +327,7 @@ def on_message(message)
           end
 
           expect(queue.pop).to eq :init
-          expect(queue.pop).to eq true
+          expect(queue.pop).to include(test)
           first_id  = queue.pop
           second_id = queue.pop.value
           expect(first_id).not_to eq second_id # context already reset
@@ -354,7 +354,7 @@ def on_message(message)
             end
 
             actor << :link
-            queue << actor.ask!(:linked?)
+            queue << actor.ask!(:linked)
             actor << nil
             queue << actor.ask(:add)
 
@@ -364,7 +364,7 @@ def on_message(message)
           end
 
           expect(queue.pop).to eq :init
-          expect(queue.pop).to eq true
+          expect(queue.pop).to include(test)
           expect(queue.pop.wait.reason).to be_a_kind_of(ActorTerminated)
           expect(queue.pop).to eq :init
           expect(queue.pop).to eq :restarted