def _on_eos(self, bus, msg):
        logger.info('%s: Pipeline received eos signal' % self.request_id)
        #self.decodebin.unlink(self.audioconvert)
        self.finish_request()
        if self.eos_handler:
            self.eos_handler[0](self.eos_handler[1])
dataset/ETHPy150Open alumae/kaldi-gstreamer-server/kaldigstserver/decoder2.py/DecoderPipeline2._on_eos/original