aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--discord/player.py10
1 files changed, 8 insertions, 2 deletions
diff --git a/discord/player.py b/discord/player.py
index cfddd2c4..3ed7fb7d 100644
--- a/discord/player.py
+++ b/discord/player.py
@@ -92,7 +92,10 @@ class PCMAudio(AudioSource):
self.stream = stream
def read(self):
- return self.stream.read(OpusEncoder.FRAME_SIZE)
+ ret = self.stream.read(OpusEncoder.FRAME_SIZE)
+ if len(ret) != OpusEncoder.FRAME_SIZE:
+ return b''
+ return ret
class FFmpegPCMAudio(AudioSource):
"""An audio source from FFmpeg (or AVConv).
@@ -155,7 +158,10 @@ class FFmpegPCMAudio(AudioSource):
raise ClientException('Popen failed: {0.__class__.__name__}: {0}'.format(e)) from e
def read(self):
- return self._stdout.read(OpusEncoder.FRAME_SIZE)
+ ret = self._stdout.read(OpusEncoder.FRAME_SIZE)
+ if len(ret) != OpusEncoder.FRAME_SIZE:
+ return b''
+ return ret
def cleanup(self):
proc = self._process