dddp/websocket.py
def on_message(self, message):
        """Process a message received from remote."""
        if self.ws.closed:
            return None
        try:
            safe_call(self.logger.debug, '< %s %r', self, message)

            # process individual messages
            for data in self.ddp_frames_from_message(message):
                self.process_ddp(data)
                # emit request_finished signal to close DB connections
                signals.request_finished.send(sender=self.__class__)
        except geventwebsocket.WebSocketError:
            self.ws.close()
def on_message(self, message):
        if self.ws.closed:
            return None
        try:
            safe_call(self.logger.debug, '< %s %r', self, message)

            # process individual messages
            for data in self.ddp_frames_from_message(message):
                self.process_ddp(data)
                # emit request_finished signal to close DB connections
                signals.request_finished.send(sender=self.__class__)
        except geventwebsocket.WebSocketError:
            self.ws.close()
def on_message ( self , message ) : if self . ws . closed : return None try : safe_call ( self . logger . debug , '< %s %r' , self , message ) # process individual messages for data in self . ddp_frames_from_message ( message ) : self . process_ddp ( data ) # emit request_finished signal to close DB connections signals . request_finished . send ( sender = self . __class__ ) except geventwebsocket . WebSocketError : self . ws . close ( )
Process a message received from remote.
Process a message received from remote .