Struct ServerMessageHandler 

pub struct ServerMessageHandler<S, A, Y>
where
    S: ServerHandler,
    A: AuthHandler,
    Y: SystemHandler,
{ /* private fields */ }

组合所有命令处理器

Implementations

impl<S, A, Y> ServerMessageHandler<S, A, Y>

where S: ServerHandler, A: AuthHandler, Y: SystemHandler,

pub fn new( auth_handler: AuthCommandHandler<A>, server_handler: ServerCommandHandler<S>, system_handler: SystemCommandHandler<Y>, ) -> Self

pub async fn handle_new_connection( &self, ctx: &AppContext, conn: &ConnectionInfo, ) -> Result<Response>

处理新链接

pub async fn handle_auth(&self, ctx: &AppContext) -> Result<Response>

认证

Trait Implementations

impl<S, A, Y> CommandHandler for ServerMessageHandler<S, A, Y>

where S: ServerHandler + Send + Sync + 'static, A: AuthHandler + Send + Sync + 'static, Y: SystemHandler + Send + Sync + 'static,

fn handle_command<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 AppContext, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

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

处理命令

fn supported_commands(&self) -> Vec<Command>

获取支持的命令列表

fn supports_command(&self, command: Command) -> bool

检查是否支持某个命令

impl<S, A, Y> Default for ServerMessageHandler<S, A, Y>

where S: ServerHandler + Default + Send + Sync + 'static, A: AuthHandler + Default + Send + Sync + 'static, Y: SystemHandler + Default + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.