Removed Broadcast because it wasn't used anywhere
Piping got rid of broadcasts. That's good.
This commit is contained in:
parent
7f74a6b56f
commit
f8112743b7
1 changed files with 0 additions and 47 deletions
|
@ -1,47 +0,0 @@
|
||||||
class Broadcast:
|
|
||||||
class ChannelError(IndexError):
|
|
||||||
def __init__(self, channel):
|
|
||||||
super(Broadcast.ChannelError, self).__init__("channel '%s' does not exist" % channel)
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
self.channels = {}
|
|
||||||
|
|
||||||
def broadcast(self, data, route, channel, exclude=[]):
|
|
||||||
if channel in self.channels:
|
|
||||||
for handler in self.channels[channel]:
|
|
||||||
if not handler in exclude:
|
|
||||||
handler.send(data, route)
|
|
||||||
else:
|
|
||||||
raise Broadcast.ChannelError(channel)
|
|
||||||
|
|
||||||
def remove(self, handler, channel):
|
|
||||||
if channel in self.channels:
|
|
||||||
if handler in self.channels[channel]:
|
|
||||||
del self.channels[channel][self.channels[channel].index(handler)]
|
|
||||||
else:
|
|
||||||
raise Broadcast.ChannelError(channel)
|
|
||||||
|
|
||||||
def add(self, handler, channel):
|
|
||||||
if channel in self.channels:
|
|
||||||
if not handler in self.channels[channel]:
|
|
||||||
self.channels[channel].append(handler)
|
|
||||||
else:
|
|
||||||
raise Broadcast.ChannelError(channel)
|
|
||||||
|
|
||||||
def add_channel(self, channel):
|
|
||||||
self.channels[channel] = []
|
|
||||||
|
|
||||||
def remove_channel(self, channel):
|
|
||||||
if channel in self.channels:
|
|
||||||
del self.channels[channel]
|
|
||||||
else:
|
|
||||||
raise Broadcast.ChannelError(channel)
|
|
||||||
|
|
||||||
def __repr__(self):
|
|
||||||
out = "Channels:\n"
|
|
||||||
for channel in self.channels:
|
|
||||||
out += "%s: %d socks\n" % (channel, len(self.channels[channel]))
|
|
||||||
return out.rstrip("\n")
|
|
||||||
|
|
||||||
def __str__(self):
|
|
||||||
return self.__repr__()
|
|
Reference in a new issue