pub async fn wait_for_persisted(write_token: impl Into<String>, connection: Connection) {
    info!("Waiting for write token to be persisted");

    wait_for_token(write_token, connection, |res| {
        if all_persisted(res) {
            info!("Write is persisted: {:?}", res);
            true
        } else {
            false
        }
    })
    .await
}
/// Waits for the write token to be persisted
Waits for the write token to be persisted
Waits for the write token to be persisted
pub async fn wait_for_persisted(write_token: impl Into<String>, connection: Connection) {
    info!("Waiting for write token to be persisted");
    wait_for_token(write_token, connection, |res| {
        if all_persisted(res) {
            info!("Write is persisted: {:?}", res);
            true
        } else {
            false
        }
    })
    .await
}
pub async fn wait_for_persisted ( write_token : impl Into < String > , connection : Connection ) { info ! ( " " ) ; wait_for_token ( write_token , connection , | res | { if all_persisted ( res ) { info ! ( " " res ) ; true } else { false } } ) . await }
Waits for the write token to be persisted
Waits for the write token to be persisted
write_token
impl Into<String>
connection
Connection
write_token
impl Into<String>
connection
Connection