Struct Streams 

pub struct Streams { /* private fields */ }

Provides atomic stream update operations

Implementations

impl Streams

pub fn new(iii: III) -> Self

Create a new Streams instance with the given iii

pub async fn update( &self, key: impl Into<String>, ops: Vec<UpdateOp>, ) -> Result<UpdateResult, IIIError>

Perform an atomic update on a stream key

All operations are applied atomically - either all succeed or none are applied.

Arguments

• key - The stream key to update (format: “stream_name::group_id::item_id”)
• ops - List of operations to apply atomically

Returns

Returns UpdateResult containing the old and new values

Example

let result = streams.update(
    "orders::user-123::order-456",
    vec![
        UpdateOp::increment("total", 100),
        UpdateOp::set("status", "processing".into()),
    ],
).await?;

pub async fn increment( &self, key: impl Into<String>, field: impl Into<String>, by: i64, ) -> Result<UpdateResult, IIIError>

Atomically increment a numeric field

Convenience method for a single increment operation.

Example

streams.increment("counters::daily::page-views", "count", 1).await?;

pub async fn decrement( &self, key: impl Into<String>, field: impl Into<String>, by: i64, ) -> Result<UpdateResult, IIIError>

Atomically decrement a numeric field

Convenience method for a single decrement operation.

pub async fn set_field( &self, key: impl Into<String>, field: impl Into<String>, value: impl Into<Value>, ) -> Result<UpdateResult, IIIError>

Atomically set a field value

Convenience method for a single set operation.

Example

streams.set_field("users::active::user-1", "status", "online".into()).await?;

pub async fn remove_field( &self, key: impl Into<String>, field: impl Into<String>, ) -> Result<UpdateResult, IIIError>

Atomically remove a field

Convenience method for a single remove operation.

pub async fn merge( &self, key: impl Into<String>, value: impl Into<Value>, ) -> Result<UpdateResult, IIIError>

Atomically merge an object into the existing value

Convenience method for a single merge operation.

Example

streams.merge(
    "settings::user-1::preferences",
    serde_json::json!({"theme": "dark", "language": "en"}),
).await?;

Trait Implementations

impl Clone for Streams

fn clone(&self) -> Streams

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.