Struct Get 

pub struct Get { /* private fields */ }

A pending fuchsia.pkg/PackageCache.Get() request. Clients must, in order:

1. open/write the meta blob, if Some(NeededBlob) is provided by that API
2. enumerate all missing content blobs
3. open/write all missing content blobs, if Some(NeededBlob) is provided by that API
4. finish() to complete the Get() request.

Implementations

impl Get

pub fn make_open_meta_blob(&mut self) -> DeferredOpenBlob

Returns an independent object that can be used to open the meta blob for write. See Self::open_meta_blob.

pub async fn open_meta_blob( &mut self, ) -> Result<Option<NeededBlob>, OpenBlobError>

Opens the meta blob for write, if it is still needed. The blob’s data can be provided using the returned NeededBlob.

pub fn get_missing_blobs( &mut self, ) -> impl Stream<Item = Result<Vec<BlobInfo>, ListMissingBlobsError>> + Unpin

Determines the set of blobs that the caller must open/write to complete this Get() operation. The returned stream will never yield an empty Vec. Callers should process the missing blobs (via make_open_blob or open_blob) concurrently with reading the stream to guarantee stream termination.

pub fn make_open_blob(&mut self, content_blob: BlobId) -> DeferredOpenBlob

Returns an independent object that can be used to open the content_blob for write. See Self::open_blob.

pub async fn open_blob( &mut self, content_blob: BlobId, ) -> Result<Option<NeededBlob>, OpenBlobError>

Opens content_blob for write, if it is still needed. The blob’s data can be provided using the returned NeededBlob.

pub async fn finish(self) -> Result<PackageDirectory, GetError>

Notifies the endpoint that all blobs have been written and wait for the response to the pending Get() request, returning the cached PackageDirectory.

pub async fn abort(self)

Aborts this caching operation for the package.

Trait Implementations

impl Debug for Get

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

Formats the value using the given formatter.