webhook.py 文件源码

def _run(self):
        def cb(s):
            msg = self._input_mapper(s)
            self._manager.add_msg(msg)

        def handle(*args):
            WebhookListener(cb, *args)

        self._server = HTTPServer(('', self._input_port), handle)
        self._server.serve_forever()