Deprecated, was not used anywhere

This commit is contained in:
Philip Trauner 2017-02-23 12:01:04 +01:00
parent 3912d9f43f
commit bf3f32c0d3

View file

@ -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__()