Trait flow_component::Operation

pub trait Operation {
    // Required method
    fn handle(
        &self,
        payload: StreamMap,
        data: Option<Value>
    ) -> BoxFuture<'_, Result<PacketStream, ComponentError>>;
}

Required Methods

fn handle( &self, payload: StreamMap, data: Option<Value> ) -> BoxFuture<'_, Result<PacketStream, ComponentError>>

Implementors