Struct FinalPartDataStream 

pub struct FinalPartDataStream<S>
where
    S: Stream<Item = Result<Bytes, Error>> + Send + Unpin,
{ /* private fields */ }

The strict variant of a taken part stream.

Created with PartDataStream::into_final, it yields the remaining data chunks of the part — each one non-empty — and then validates the strict closing trailer: \r\n--boundary--\r\n followed by end of stream, with transport padding (SP / HTAB) allowed between the closing -- and the final CRLF, as RFC 2046 section 5.1.1 allows for a boundary line. An epilogue or another part is rejected because callers derive the exact content length from the multipart byte accounting.

Implementations

impl<S> FinalPartDataStream<S>

where S: Stream<Item = Result<Bytes, Error>> + Send + Unpin,

pub fn multipart_consumed(&self) -> u64

Returns the total number of multipart bytes consumed at the moment the stream was taken, excluding bytes retained in the internal buffer.

This is the value to subtract from the request Content-Length when deriving the exact file length. It does not count bytes yielded by this stream itself.

Trait Implementations

impl<S> Debug for FinalPartDataStream<S>

where S: Stream<Item = Result<Bytes, Error>> + Send + Unpin,

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

Formats the value using the given formatter.

impl<S> Stream for FinalPartDataStream<S>

where S: Stream<Item = Result<Bytes, Error>> + Send + Unpin,

type Item = Result<Bytes, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.