def cancel(self):
        logger.info("%s: Sending EOS to pipeline in order to cancel processing" % self.request_id)
        self.appsrc.emit("end-of-stream")
        #self.asr.set_property("silent", True)
        #self.pipeline.set_state(Gst.State.NULL)

        #if (self.pipeline.get_state() == Gst.State.PLAYING):
        #logger.debug("Sending EOS to pipeline")
        #self.pipeline.send_event(Gst.Event.new_eos())
        #self.pipeline.set_state(Gst.State.READY)
        logger.info("%s: Cancelled pipeline" % self.request_id)
dataset/ETHPy150Open alumae/kaldi-gstreamer-server/kaldigstserver/decoder2.py/DecoderPipeline2.cancel/original