Struct DelegateProcessor 

pub struct DelegateProcessor { /* private fields */ }

委托处理器

将消息委托给其他处理器（如 ConnectionHandler）

Implementations

impl DelegateProcessor

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

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

创建新的委托处理器

Trait Implementations

impl MessageProcessor for DelegateProcessor

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

处理器名称