Struct SubscribePrimingChunk 

pub struct SubscribePrimingChunk<'a> { /* private fields */ }

First (possibly only) priming ReportData chunk of a subscribe transaction. Returned by SubscribeSender::tx once the peer has ACK-ed the SubscribeRequest and the first ReportData is parsed. Same response() shape as ReadRespChunk.

Walk the priming sequence — and pick up the final SubscribeEstablished — via Self::complete.

Implementations

impl<'a> SubscribePrimingChunk<'a>

pub fn response(&self) -> Result<ReportDataResp<'_>, Error>

Borrowed access to the parsed ReportDataResp for this priming chunk. The returned value points into the exchange’s RX buffer; its lifetime is the borrow of this chunk.

pub async fn complete(self) -> Result<SubscribeOutcome<'a>, Error>

ACK the current priming chunk and advance to the next stage:

• If the chunk’s more_chunks=true: send StatusResponse(Success), fetch the next priming ReportData, and return Ok(NextChunk(self)).
• If more_chunks=false: send the trailing StatusResponse(Success), then await + parse the peer’s SubscribeResponse, and return Ok(Established(...)) with the subscription id and chosen max interval.
• If the priming stream is aborted (peer sends StatusResponse(non-Success) instead of either ReportData or SubscribeResponse), return Err.

Trait Implementations

impl<'a> Debug for SubscribePrimingChunk<'a>

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

Formats the value using the given formatter.