Trait drone_core::fib::ThrFiberStreamPulse

pub trait ThrFiberStreamPulse: ThrToken {
    pub fn add_saturating_pulse_stream<F>(self, fib: F) -> FiberStreamPulse
    where
        F: Fiber<Input = (), Yield = Option<usize>, Return = Option<usize>>,
        F: Send + 'static,
    { ... }
    pub fn add_pulse_try_stream<O, F, E>(
        self, 
        overflow: O, 
        fib: F
    ) -> TryFiberStreamPulse<E>
    where
        O: Fn() -> Result<(), E>,
        F: Fiber<Input = (), Yield = Option<usize>, Return = Result<Option<usize>, E>>,
        O: Send + 'static,
        F: Send + 'static,
        E: Send + 'static,
    { ... }
}

Extends ThrToken types with pulse stream methods.

Provided methods

pub fn add_saturating_pulse_stream<F>(self, fib: F) -> FiberStreamPulse where
    F: Fiber<Input = (), Yield = Option<usize>, Return = Option<usize>>,
    F: Send + 'static, 

Adds the fiber fib to the fiber chain and returns a stream of pulses yielded from the fiber.

pub fn add_pulse_try_stream<O, F, E>(
    self,
    overflow: O,
    fib: F
) -> TryFiberStreamPulse<E> where
    O: Fn() -> Result<(), E>,
    F: Fiber<Input = (), Yield = Option<usize>, Return = Result<Option<usize>, E>>,
    O: Send + 'static,
    F: Send + 'static,
    E: Send + 'static, 

Adds the fiber fib to the fiber chain and returns a fallible stream of pulses yielded from the fiber.

Loading content...

Implementors

impl<T: ThrToken> ThrFiberStreamPulse for T

Loading content...