Struct Parser
pub struct Parser { /* private fields */ }Available on crate features
http and multipart and std only.Expand description
Sans-IO parser of a multipart/form-data body.
Drive it with step: on Event::NeedInput hand it the
next body chunk with feed, or call
set_eof once the body is over. It never reads, waits or
buffers part data, so it serves a server reading a form as much as a proxy
rewriting one as it streams by (see Encoder).
An error is final: every later step returns it again.
Implementations§
§impl Parser
impl Parser
pub const MAX_HEAD_SIZE: usize = MAX_HEAD_SIZE
pub const MAX_HEAD_SIZE: usize = MAX_HEAD_SIZE
Upper bound for the header block of a single part, in bytes.
pub const MAX_HEADERS: usize = MAX_HEADERS
pub const MAX_HEADERS: usize = MAX_HEADERS
Upper bound for the number of header lines of a single part.
pub fn wants_input(&self) -> bool
pub fn wants_input(&self) -> bool
Whether more input would be put to use: false once the close delimiter is read or parsing failed.
pub fn feed(&mut self, chunk: Bytes)
pub fn feed(&mut self, chunk: Bytes)
Hand over the next body chunk, only after Event::NeedInput.
pub fn set_eof(&mut self)
pub fn set_eof(&mut self)
Signal that the body has no more chunks.
pub fn step(&mut self) -> Result<Event, ParseError>
pub fn step(&mut self) -> Result<Event, ParseError>
Advance to the next event.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for Parser
impl Forget for Parser
impl RefUnwindSafe for Parser
impl Send for Parser
impl Sync for Parser
impl Unpin for Parser
impl UnsafeUnpin for Parser
impl UnwindSafe for Parser
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more