Weave documentation
Rust referenceweave-agentfs-diff

weave-agentfs-diff · stream

Source declarations, signatures and documentation for stream.

Source: sigil/weave/local/agentfs-diff/src/stream.rs. SHA-256: bd77ec4614ff864a42d4eb2757c6cf291a6ff1e7d3cd495d8ac8af10fc18f9c6.

This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.

stream::DiffEvent

Events emitted during diff streaming

#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum DiffEvent {
    /// Starting comparison
    Started {
        source_type: String,
        target_type: String,
    },

    /// Found a difference
    DiffFound(Box<Diff>),

    /// Progress update
    Progress {
        current_path: String,
        files_compared: usize,
    },

    /// Comparison completed
    Completed {
        total_diffs: usize,
        duration_ms: u64,
    },

    /// Error occurred
    Error(String),
}

Source line: 20.

stream::DiffStream

Streaming diff implementation

#[pin_project]
pub struct DiffStream {

}

Source line: 48.

stream::DiffStream::new

Create a new diff stream

pub fn new(
        source: std::sync::Arc<dyn FileSystem>,
        target: std::sync::Arc<dyn FileSystem>,
        options: DiffOptions,
    ) -> Self;

Source line: 56.

stream::DiffStream::abort

Abort the comparison

pub fn abort(&mut self);

Source line: 104.

On this page