Struct FunctionProcessor 

pub struct FunctionProcessor { /* private fields */ }

函数式消息处理器

使用闭包处理消息，适合简单场景

Implementations

impl FunctionProcessor

pub fn new<F, Fut>(name: impl Into<String>, handler: F) -> Self

where F: Fn(&MessageContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Option<Frame>>> + Send + 'static,

创建新的函数式处理器

Trait Implementations

impl MessageProcessor for FunctionProcessor

fn process<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 MessageContext, ) -> Pin<Box<dyn Future<Output = Result<Option<Frame>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

处理消息

fn name(&self) -> &str

处理器名称