Struct mz_storage_client::source::persist_source::FlowControl

pub struct FlowControl<G>where
    G: Scope,{
    pub progress_stream: StreamCore<G, Vec<Infallible, Global>>,
    pub max_inflight_bytes: usize,
}

Flow control configuration.

Fields

progress_stream: StreamCore<G, Vec<Infallible, Global>>

Stream providing in-flight frontier updates.

As implied by its type, this stream never emits data, only progress updates.

TODO: Replace Infallible with ! once the latter is stabilized.

max_inflight_bytes: usize

Maximum number of in-flight bytes.

Trait Implementations

impl<G> Debug for FlowControl<G>where
    G: Debug + Scope,

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

Formats the value using the given formatter.