Struct StreamExecutor 

pub struct StreamExecutor { /* private fields */ }

Executes streaming operations with bounded concurrency.

Construct via StorageService::stream, which pre-acquires the concurrency window from the service’s available permits.

See the module documentation for a full description of the window calculation, permit reservation, and concurrency model.

Implementations

impl StreamExecutor

pub fn window(&self) -> usize

Returns the concurrency window computed at construction.

pub fn execute<E>( self, context: ObjectContext, operations: impl Stream<Item = (usize, Result<Operation, E>)> + Send + 'static, ) -> impl Stream<Item = (usize, Result<OpResponse, E>)> + Send + 'static

where E: From<Error> + Send + 'static,

Executes the operations stream with bounded concurrency.

Each item is a (index, Result<Operation, E>) tuple where index is the 0-based position of the operation in the original request. Error items pass through immediately; successful items are executed concurrently up to window at a time, each in an isolated [tokio::spawn].

Results are yielded in completion order (not submission order). The permit reservation is held until every spawned task has completed — if the stream is dropped early, in-flight tasks run to completion before the permits are released.

Trait Implementations

impl Debug for StreamExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.