Trait protoflow_blocks::CoreBlocks

pub trait CoreBlocks {
    // Required methods
    fn buffer<T: Message + Into<T> + 'static>(&self) -> Buffer<T>;
    fn const_string(&self, value: impl ToString) -> Const<String>;
    fn count<T: Message + 'static>(&self) -> Count<T>;
    fn delay<T: Message + 'static>(&self) -> Delay<T>;
    fn delay_by<T: Message + 'static>(&self, delay: DelayType) -> Delay<T>;
    fn drop<T: Message + 'static>(&self) -> Drop<T>;
    fn random<T: Message + 'static>(&self) -> Random<T>;
    fn random_seeded<T: Message + 'static>(
        &self,
        seed: Option<u64>,
    ) -> Random<T>;

    // Provided methods
    fn delay_by_fixed<T: Message + 'static>(&self, delay: Duration) -> Delay<T> { ... }
    fn delay_by_random<T: Message + 'static>(
        &self,
        delay: Range<Duration>,
    ) -> Delay<T> { ... }
}

Required Methods

fn buffer<T: Message + Into<T> + 'static>(&self) -> Buffer<T>

fn const_string(&self, value: impl ToString) -> Const<String>

fn count<T: Message + 'static>(&self) -> Count<T>

fn delay<T: Message + 'static>(&self) -> Delay<T>

fn delay_by<T: Message + 'static>(&self, delay: DelayType) -> Delay<T>

fn drop<T: Message + 'static>(&self) -> Drop<T>

fn random<T: Message + 'static>(&self) -> Random<T>

fn random_seeded<T: Message + 'static>(&self, seed: Option<u64>) -> Random<T>

Provided Methods

fn delay_by_fixed<T: Message + 'static>(&self, delay: Duration) -> Delay<T>

fn delay_by_random<T: Message + 'static>( &self, delay: Range<Duration>, ) -> Delay<T>

Object Safety

This trait is not object safe.

Implementors

impl CoreBlocks for System