Skip to main content

build_event_push_frame

reddb_server::wire::redwire::queue_wait

Function build_event_push_frame 

Source 
pub fn build_event_push_frame(
    correlation_id: u64,
    stream_id: u16,
    message: &Value,
) -> Result<Frame, BuildError>
Expand description

Build a QueueEventPush frame echoing the open request’s correlation_id and stream_id so the client pairs the push with the wait it opened.