def receive()

in apisix/runner/server/server.py [0:0]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    def receive(self):
        while True:
            conn, address = self.sock.accept()
            conn.settimeout(60)

            r = RPCRequest(conn, self.logger)
            thread = NewThread(target=_threaded, args=(r,))
            thread.setDaemon(True)
            thread.start()