Function state_write_with_events 

pub fn state_write_with_events<S, R, E>(
    storage: &S,
    bus: &EventBus<InternalEvent>,
    operation: impl FnOnce(&mut StateTx<'_, <S as XmtpMlsStorageProvider>::TxQuery>, &EventBuffer<'_, InternalEvent>) -> Result<TransactionOutcome<R>, E>,
) -> Result<TransactionOutcome<R>, E>
where
    S: XmtpMlsStorageProvider,
    E: From<Error> + From<ConnectionError> + Error,

Flush this write’s events only after its database transaction commits.