Skip to main content

process_streamed_group_message

Function process_streamed_group_message 

Source
pub async fn process_streamed_group_message<Context>(
    group: &MlsGroup<Context>,
    envelope_bytes: Vec<u8>,
) -> Result<Vec<StoredGroupMessage>, SubscribeError>
where Context: XmtpSharedContext + 'static,
Expand description

Use a push envelope for group only as a target for ordered receipt and processing.