[holster] update Emitter instances to use `spawn_each`

disco/client.py

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

disco/util/websocket.py

@@ -1,7 +1,6 @@
 from __future__ import absolute_import
 
 import websocket
-import gevent
 import six
 
 from holster.emitter import Emitter
@@ -21,7 +20,7 @@ class Websocket(LoggingClass, websocket.WebSocketApp):
         LoggingClass.__init__(self)
         websocket.WebSocketApp.__init__(self, *args, **kwargs)
 
-        self.emitter = Emitter(gevent.spawn)
+        self.emitter = Emitter(spawn_each=True)
 
         # Hack to get events to emit
         for var in six.iterkeys(self.__dict__):

disco/voice/client.py

@@ -129,13 +129,13 @@ class VoiceClient(LoggingClass):
         self.encoder = encoder or JSONEncoder
 
         # Bind to some WS packets
-        self.packets = Emitter(gevent.spawn)
+        self.packets = Emitter(spawn_each=True)
         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(gevent.spawn)
+        self.state_emitter = Emitter(spawn_each=True)
 
         # Connection metadata
         self.token = None

disco/voice/player.py

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