Skip to main content

pull_stream

Function pull_stream 

Source
pub(crate) fn pull_stream<ObjectID: FsVerityHashValue>(
    repo: Arc<Repository<ObjectID>>,
    image: String,
    name: Option<String>,
    local_fetch: LocalFetchOpt,
    storage_root: Option<PathBuf>,
    bootable: bool,
    more: bool,
) -> Pin<Box<dyn Stream<Item = Result<Reply<PullProgress>, OciError>> + Send>>
Expand description

Run a streaming pull against an already-opened repository, returning a boxed stream of PullProgress frames.

The return type is a concrete boxed trait object rather than impl Stream so that both monomorphisations (Sha256/Sha512) of this generic function produce the same type — letting the non-generic service pull method unify the two match arms under a single impl Stream return.

When more is false the client asked for a single reply, so no progress reporter is attached and the stream yields only the terminal completed frame (or an error).