def xrange(self, stream, start='-', stop='+', count=None):
        """Retrieve messages from a stream."""
        if count is not None:
            extra = ['COUNT', count]
        else:
            extra = []
        fut = self.execute(b'XRANGE', stream, start, stop, *extra)
        return wait_convert(fut, parse_messages)
def xrange ( self , stream , start = '-' , stop = '+' , count = None ) : if count is not None : extra = [ 'COUNT' , count ] else : extra = [ ] fut = self . execute ( b'XRANGE' , stream , start , stop , * extra ) return wait_convert ( fut , parse_messages )
Retrieve messages from a stream.