Method close

lmdeploy/pipeline.py:589–594

(self)

                })

    def close(self):
        if self.closed:
            return
        self.closed = True
        self.loop.call_soon_threadsafe(self.loop.stop)
        self.thread.join()