Broadcast to filtered_receivers only not all receivers

Author: pitr-ch

lib/concurrent/actor/utils/broadcast.rb

@@ -18,12 +18,12 @@ def on_message(message)
           when :subscribed?
             @receivers.include? envelope.sender
           else
-            @receivers.each { |r| r << message }
+            filtered_receivers.each { |r| r << message }
           end
         end
 
         # override to define different behaviour, filtering etc
-        def receivers
+        def filtered_receivers
           @receivers
         end
       end