Skip to content

Commit dc87b3d

Browse files
committed
Broadcast returns true/false
as a result of mesage processing :subscribe and :unsubscribe
1 parent 96cea54 commit dc87b3d

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

lib/concurrent/actor/utils/broadcast.rb

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,8 @@
33
module Concurrent
44
module Actor
55
module Utils
6+
7+
# TODO doc
68
class Broadcast < Context
79

810
def initialize
@@ -13,8 +15,10 @@ def on_message(message)
1315
case message
1416
when :subscribe
1517
@receivers.add envelope.sender
18+
true
1619
when :unsubscribe
1720
@receivers.delete envelope.sender
21+
true
1822
when :subscribed?
1923
@receivers.include? envelope.sender
2024
else

0 commit comments

Comments
 (0)