async def METHOD_NAME(self):
    client = LogClient(self.ctx_cluster, self.namespace, self.pod)
    async for line in client.stream(self.filter):
        if self.closed is True:
            return
        # k8s返回使用空格分隔
        t, _, log = line.partition(' ')
        data = {"streams": [{'time': t, 'log': log}]}
        try:
            await self.send(text_data=json.dumps(data))
        except Exception as error:
            logger.error("reader error: %s", error)
            return