im-core 0.1.0

Rust IM SDK for Awiki clients built on Agent Network Protocol (ANP)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use std::sync::mpsc;
use std::thread::JoinHandle;

pub type RealtimeEventReceiver = mpsc::Receiver<super::ImEvent>;

pub struct RealtimeHandle {
    pub events: RealtimeEventReceiver,
    pub control: super::RealtimeControl,
    _worker: Option<JoinHandle<()>>,
}

impl RealtimeHandle {
    pub(crate) fn new(events: RealtimeEventReceiver, control: super::RealtimeControl) -> Self {
        Self {
            events,
            control,
            _worker: None,
        }
    }

    pub(crate) fn with_worker(
        events: RealtimeEventReceiver,
        control: super::RealtimeControl,
        worker: JoinHandle<()>,
    ) -> Self {
        Self {
            events,
            control,
            _worker: Some(worker),
        }
    }
}