examples/rpc-server.py
def process_input(self):
        """Called when socket is read-ready"""
        try:
            pyngus.read_socket_input(self.connection, self.socket)
        except Exception as e:
            LOG.error("Exception on socket read: %s", str(e))
            self.connection.close_input()
            self.connection.close()
        self.connection.process(time.time())
def process_input(self):
        try:
            pyngus.read_socket_input(self.connection, self.socket)
        except Exception as e:
            LOG.error("Exception on socket read: %s", str(e))
            self.connection.close_input()
            self.connection.close()
        self.connection.process(time.time())
def process_input ( self ) : try : pyngus . read_socket_input ( self . connection , self . socket ) except Exception as e : LOG . error ( "Exception on socket read: %s" , str ( e ) ) self . connection . close_input ( ) self . connection . close ( ) self . connection . process ( time . time ( ) )
Called when socket is read-ready
Called when socket is read - ready