btfxwss/queue_processor.py
def _handle_auth(self, dtype, data, ts):
        """Handles authentication responses.

        :param dtype:
        :param data:
        :param ts:
        :return:
        """
        # Contains keys status, chanId, userId, caps
        if dtype == 'unauth':
            raise NotImplementedError
        channel_id = data.pop('chanId')
        user_id = data.pop('userId')

        identifier = ('auth', user_id)
        self.channel_handlers[identifier] = channel_id
        self.channel_directory[identifier] = channel_id
        self.channel_directory[channel_id] = identifier
def _handle_auth(self, dtype, data, ts):
        # Contains keys status, chanId, userId, caps
        if dtype == 'unauth':
            raise NotImplementedError
        channel_id = data.pop('chanId')
        user_id = data.pop('userId')

        identifier = ('auth', user_id)
        self.channel_handlers[identifier] = channel_id
        self.channel_directory[identifier] = channel_id
        self.channel_directory[channel_id] = identifier
def _handle_auth ( self , dtype , data , ts ) : # Contains keys status, chanId, userId, caps if dtype == 'unauth' : raise NotImplementedError channel_id = data . pop ( 'chanId' ) user_id = data . pop ( 'userId' ) identifier = ( 'auth' , user_id ) self . channel_handlers [ identifier ] = channel_id self . channel_directory [ identifier ] = channel_id self . channel_directory [ channel_id ] = identifier
Handles authentication responses.

        :param dtype:
        :param data:
        :param ts:
        :return:
Handles authentication responses .