Function get_stream_message

tests/test_commands.py:68–72

Fetch a stream message and format it as a (message_id, fields) pair

(client, stream, message_id)

def get_stream_message(client, stream, message_id):
    "Fetch a stream message and format it as a (message_id, fields) pair"
    response = client.xrange(stream, min=message_id, max=message_id)
    assert len(response) == 1
    return response[0]


# RESPONSE CALLBACKS