allow binding to celery task

Author: Forchapeatl

ffmpeg_streaming/_process.py

@@ -88,7 +88,7 @@ def _monitor(self):
             if callable(self.monitor):
                 duration = get_time('Duration: ', line, duration)
                 _time = get_time('time=', line, _time)
-                self.monitor(line, duration, _time, time_left(start_time, _time, duration), self.process)
+                self.monitor(self,line, duration, _time, time_left(start_time, _time, duration), self.process)
 
         Process.out = log