Counter¶

use futures::TryStreamExt;
use scylla::frame::value::Counter;

// Add to counter value
let to_add: Counter = Counter(100);
session
    .query_unpaged("UPDATE keyspace.table SET c = c + ? WHERE pk = 15", (to_add,))
    .await?;

// Read counter from the table
let mut stream = session.query_iter("SELECT c FROM keyspace.table", &[])
    .await?
    .rows_stream::<(Counter,)>()?;
while let Some((counter_value,)) = stream.try_next().await? {
    let counter_int_value: i64 = counter_value.0;
    println!("{}", counter_int_value);
}