Struct ReliableWithBackpressure

Source

pub struct ReliableWithBackpressure;

Expand description

Reliable stream delivery marker that applies backpressure to the child to keep active subscribers gap-free.

Mechanism: When an active subscriber’s buffer is full, the reader task waits before reading more from the child’s pipe. The kernel pipe then fills and the child’s next write blocks. This is the cost paid for reliability.

Scope: The guarantee applies only to subscribers that are currently attached when each chunk is produced. Subscribers that attach later do not retroactively receive earlier chunks from this delivery policy; that is what the replay axis is for.

ReliableWithBackpressure

Struct ReliableWithBackpressure Copy item path

Trait Implementations§

impl Clone for ReliableWithBackpressure

fn clone(&self) -> ReliableWithBackpressure

fn clone_from(&mut self, source: &Self)

impl Copy for ReliableWithBackpressure

impl Debug for ReliableWithBackpressure

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

impl Delivery for ReliableWithBackpressure

fn guarantee(self) -> DeliveryGuarantee

impl Eq for ReliableWithBackpressure

impl PartialEq for ReliableWithBackpressure

fn eq(&self, other: &ReliableWithBackpressure) -> bool

fn ne(&self, other: &Rhs) -> bool

impl StructuralPartialEq for ReliableWithBackpressure

Auto Trait Implementations§

impl Freeze for ReliableWithBackpressure

impl RefUnwindSafe for ReliableWithBackpressure

impl Send for ReliableWithBackpressure

impl Sync for ReliableWithBackpressure

impl Unpin for ReliableWithBackpressure

impl UnsafeUnpin for ReliableWithBackpressure

impl UnwindSafe for ReliableWithBackpressure

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Sink for Twhere T: Send + 'static,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ReliableWithBackpressure

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> Sink for T
where T: Send + 'static,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,