Skip to main content

stream_conversation_messages_with_callback_dispatch

xmtp_mls::subscriptions::router_callbacks

Function stream_conversation_messages_with_callback_dispatch 

Source 
pub fn stream_conversation_messages_with_callback_dispatch<C>(
    context: C,
    group_id: GroupId,
    callback: impl FnMut(Result<StoredGroupMessage, SubscribeError>) + MaybeSend + 'static,
    on_close: impl FnOnce() + MaybeSend + 'static,
) -> impl StreamHandle<StreamOutput = Result<(), SubscribeError>>
where
    C: XmtpSharedContext + 'static,
    C::ApiClient: XmtpMlsBidiStreams + XmtpMlsStreams + ApiClientIdentity + Clone + Send + Sync + 'static,
    <C::ApiClient as XmtpMlsBidiStreams>::SubscribeStream: 'static,