Browse Source

Remove spawn_each args during Emitter init

pull/62/head
Kodie 8 years ago
parent
commit
65e63a45f9
  1. 4
      disco/client.py
  2. 2
      disco/util/websocket.py
  3. 4
      disco/voice/client.py
  4. 2
      disco/voice/player.py

4
disco/client.py

@ -88,8 +88,8 @@ class Client(LoggingClass):
super(Client, self).__init__()
self.config = config
self.events = Emitter(spawn_each=True)
self.packets = Emitter(spawn_each=True)
self.events = Emitter()
self.packets = Emitter()
self.api = APIClient(self.config.token, self)
self.gw = GatewayClient(self, self.config.max_reconnects, self.config.encoder)

2
disco/util/websocket.py

@ -20,7 +20,7 @@ class Websocket(LoggingClass, websocket.WebSocketApp):
LoggingClass.__init__(self)
websocket.WebSocketApp.__init__(self, *args, **kwargs)
self.emitter = Emitter(spawn_each=True)
self.emitter = Emitter()
# Hack to get events to emit
for var in six.iterkeys(self.__dict__):

4
disco/voice/client.py

@ -129,13 +129,13 @@ class VoiceClient(LoggingClass):
self.encoder = encoder or JSONEncoder
# Bind to some WS packets
self.packets = Emitter(spawn_each=True)
self.packets = Emitter()
self.packets.on(VoiceOPCode.READY, self.on_voice_ready)
self.packets.on(VoiceOPCode.SESSION_DESCRIPTION, self.on_voice_sdp)
# State + state change emitter
self.state = VoiceState.DISCONNECTED
self.state_emitter = Emitter(spawn_each=True)
self.state_emitter = Emitter()
# Connection metadata
self.token = None

2
disco/voice/player.py

@ -44,7 +44,7 @@ class Player(object):
self.complete = gevent.event.Event()
# Event emitter for metadata
self.events = Emitter(spawn_each=True)
self.events = Emitter()
def disconnect(self):
self.client.disconnect()

Loading…
Cancel
Save