Trait Transform 

pub trait Transform: Send {
    // Required method
    fn run<'async_trait>(
        self: Box<Self>,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait;

    // Provided method
    fn spawn(self: Box<Self>) -> JoinHandle<()>
       where Self: 'static { ... }
}

Required Methods

fn run<'async_trait>( self: Box<Self>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,

Provided Methods

fn spawn(self: Box<Self>) -> JoinHandle<()>

where Self: 'static,

Implementors

impl Transform for AggregateTask

impl Transform for FilterTask

impl Transform for OtelAggregateTask

impl Transform for SampleTask

impl Transform for SqlMapTask

impl Transform for WasmTransformTask