Added routing support to broadcast
This commit is contained in:
parent
d287a84950
commit
512f70aa36
1 changed files with 2 additions and 2 deletions
|
@ -6,11 +6,11 @@ class Broadcast:
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self.channels = {}
|
self.channels = {}
|
||||||
|
|
||||||
def broadcast(self, data, channel, exclude=[]):
|
def broadcast(self, data, route, channel, exclude=[]):
|
||||||
if channel in self.channels:
|
if channel in self.channels:
|
||||||
for sock in self.channels[channel]:
|
for sock in self.channels[channel]:
|
||||||
if not sock in exclude:
|
if not sock in exclude:
|
||||||
sock.send(data)
|
sock.send(data, route)
|
||||||
else:
|
else:
|
||||||
raise Broadcast.ChannelError(channel)
|
raise Broadcast.ChannelError(channel)
|
||||||
|
|
||||||
|
|
Reference in a new issue