(self)
Consume value gotten from queue.
        Raise UserWarning if consume() called before get()
Consume value gotten from queue.
        Raise UserWarning if consume() called before get()
Consume value gotten from queue . Raise UserWarning if consume () called before get ()
def consume(self):
        """Consume value gotten from queue.
        Raise UserWarning if consume() called before get()
        """
        if self._item is None:
            raise UserWarning("Must call get() before consume()")

        self.LOCKS.pop(self._h_k)

        rv = raw_client().evalsha(
            self._SHAS['lq_consume'],
            len(self.SCRIPTS['lq_consume']['keys']),
            self._h_k, self._path, self._q_lookup, self._client_id)
        assert rv == 1

        self._h_k = None
        self._item = None
def consume ( self ) : if self . _item is None : raise UserWarning ( "Must call get() before consume()" ) self . LOCKS . pop ( self . _h_k ) rv = raw_client ( ) . evalsha ( self . _SHAS [ 'lq_consume' ] , len ( self . SCRIPTS [ 'lq_consume' ] [ 'keys' ] ) , self . _h_k , self . _path , self . _q_lookup , self . _client_id ) assert rv == 1 self . _h_k = None self . _item = None