Skip to main content

parse_stream_response

Function parse_stream_response 

Source
pub fn parse_stream_response(
    value: &Value,
) -> Vec<(String, Vec<(String, String)>)>
Expand description

Parse the response from XREADGROUP into a list of (msg_id, fields) tuples.

XREADGROUP returns: [[stream_key, [[msg_id, [field, value, ...]], ...]]]