pub struct Framer { /* private fields */ }Expand description
The incremental framer of one streamed reply, from Framing::framer.
Implementations§
Source§impl Framer
impl Framer
Sourcepub fn push(&mut self, chunk: &[u8]) -> impl Iterator<Item = WireFrame> + '_
pub fn push(&mut self, chunk: &[u8]) -> impl Iterator<Item = WireFrame> + '_
Feed one transport chunk; yields every frame it completed. An SSE event whose data is only whitespace is a heartbeat, not a frame.
Sourcepub fn finish(&mut self) -> Option<WireFrame>
pub fn finish(&mut self) -> Option<WireFrame>
The stream ended: NDJSON’s unterminated last line. SSE dispatches only on a blank line, so an unterminated event is never a frame.
Sourcepub fn pending(&self) -> usize
pub fn pending(&self) -> usize
Bytes pushed but not yet part of a frame, for truncation
diagnostics: SseFramer::pending or NdjsonFramer::pending.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Framer
impl RefUnwindSafe for Framer
impl Send for Framer
impl Sync for Framer
impl Unpin for Framer
impl UnsafeUnpin for Framer
impl UnwindSafe for Framer
Blanket Implementations§
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