From 78ac2c433837e72dc1933fa4a61f884b7830f2a5 Mon Sep 17 00:00:00 2001
From: Andrei <b1naryth1ef@gmail.com>
Date: Mon, 17 Jul 2017 08:46:48 -0700
Subject: [PATCH] [voice] add on_complete callback to DCADOpusEncoderPlayable

---
 disco/voice/playable.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/disco/voice/playable.py b/disco/voice/playable.py
index 35fbf8b..ff3ba04 100644
--- a/disco/voice/playable.py
+++ b/disco/voice/playable.py
@@ -227,6 +227,7 @@ class DCADOpusEncoderPlayable(BasePlayable, AbstractOpus, OpusEncoder):
     def __init__(self, source, *args, **kwargs):
         self.source = source
         self.command = kwargs.pop('command', 'dcad')
+        self.on_complete = kwargs.pop('on_complete', None)
         super(DCADOpusEncoderPlayable, self).__init__(*args, **kwargs)
 
         self._done = False
@@ -270,6 +271,7 @@ class DCADOpusEncoderPlayable(BasePlayable, AbstractOpus, OpusEncoder):
         header = self.proc.stdout.read(OPUS_HEADER_SIZE)
         if len(header) < OPUS_HEADER_SIZE:
             self._done = True
+            self.on_complete()
             return
 
         size = struct.unpack('<h', header)[0]
@@ -277,6 +279,7 @@ class DCADOpusEncoderPlayable(BasePlayable, AbstractOpus, OpusEncoder):
         data = self.proc.stdout.read(size)
         if len(data) < size:
             self._done = True
+            self.on_complete()
             return
 
         return data