Struct DingTalkStream 

pub struct DingTalkStream { /* private fields */ }

DingTalk Stream Client

Implementations

impl DingTalkStream

pub async fn start( self: Arc<Self>, ) -> Result<(Arc<Self>, JoinHandle<Result<()>>)>

Start the client and run forever (auto-reconnect)

impl DingTalkStream

pub async fn send_message<M: Into<RobotMessage>>( &self, message: M, ) -> Result<()>

impl DingTalkStream

pub fn new(credential: Credential) -> Self

Create a new DingTalk Stream client

pub fn with_config(credential: Credential, config: ClientConfig) -> Self

Create with custom configuration

impl DingTalkStream

pub async fn register_event_handler<H: EventHandler + 'static>( self, handler: Arc<H>, ) -> Self

Register an event handler

pub async fn register_callback_handler<H: CallbackHandler + 'static>( self, handler: Arc<H>, ) -> Self

Register a callback handler for a specific topic

pub async fn register_system_handler<H: SystemHandler + 'static>( self, handler: Arc<H>, ) -> Self

Register a system handler

pub async fn register_lifecycle_listener<L: LifecycleListener + 'static>( self, listener: Arc<L>, ) -> Self

impl DingTalkStream

pub fn is_connected(&self) -> bool

Check if connected

pub fn is_registered(&self) -> bool

Check if registered

pub fn credential(&self) -> &Credential

Get the credential

pub fn config(&self) -> &ClientConfig

Get configuration