pyngus/endpoint.py
def _process_endpoint_event(self, event):
        """Called when the Proton Engine generates an endpoint state change
        event.
        """
        state_fsm = Endpoint._FSM[self._state]
        entry = state_fsm.get(event)
        if not entry:
            # protocol error: invalid event for current state
            old_state = self._state
            self._state = Endpoint.STATE_ERROR
            self._ep_error("invalid event=%s in state=%s" %
                           (Endpoint.EVENT_NAMES[event],
                            Endpoint.STATE_NAMES[old_state]))
            return

        self._state = entry[0]
        if entry[1]:
            entry[1](self)
def _process_endpoint_event(self, event):
        state_fsm = Endpoint._FSM[self._state]
        entry = state_fsm.get(event)
        if not entry:
            # protocol error: invalid event for current state
            old_state = self._state
            self._state = Endpoint.STATE_ERROR
            self._ep_error("invalid event=%s in state=%s" %
                           (Endpoint.EVENT_NAMES[event],
                            Endpoint.STATE_NAMES[old_state]))
            return

        self._state = entry[0]
        if entry[1]:
            entry[1](self)
def _process_endpoint_event ( self , event ) : state_fsm = Endpoint . _FSM [ self . _state ] entry = state_fsm . get ( event ) if not entry : # protocol error: invalid event for current state old_state = self . _state self . _state = Endpoint . STATE_ERROR self . _ep_error ( "invalid event=%s in state=%s" % ( Endpoint . EVENT_NAMES [ event ] , Endpoint . STATE_NAMES [ old_state ] ) ) return self . _state = entry [ 0 ] if entry [ 1 ] : entry [ 1 ] ( self )
Called when the Proton Engine generates an endpoint state change
        event.
Called when the Proton Engine generates an endpoint state change event .