Struct ProviderPlanSession 

pub struct ProviderPlanSession<W: MessageWriter<Error = Error>, R: MessageReader<Error = Error>> { /* private fields */ }

Only an issued plan matching the signed candidate can reach this stage.

Implementations

impl<W: MessageWriter<Error = Error>, R: MessageReader<Error = Error>> ProviderPlanSession<W, R>

pub fn plan(&self) -> &ProviderPlan

The exact ticketed layout admitted after client consent.

pub fn ready(&self) -> &TransferReady

The exact issuer admission that preceded the unsigned offer.

pub async fn receive_inline(&mut self, scratch: &Path) -> Result<(), Error>

Reserve a bounded virtual pack and receive only the issuer’s inline records. Every chunk must name its exact record and next offset; the wire framing cannot allocate or write outside the canonical layout. The session retains the spool for separately authorized provider ranges.

pub async fn receive_provider_ranges<T: RpcTransport<Error = Error>>( &mut self, providers: &[Remote<T>], ) -> Result<(), Error>

Read each ticketed physical range from its exact provider endpoint. The provider cannot change virtual placement: every byte is written only into its precommitted record, then independently rehashed.

pub async fn complete(self, scratch: &Path) -> Result<StagedSource, Error>

Finalize exact pack integrity and signed source closure before sending the provider result. A terminal Complete must acknowledge the same transfer, plan and verified output length before staging is returned.