asyn-rs 0.9.1

Rust port of EPICS asyn - async device I/O framework
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
33
34
35
36
37
38

use std::future::Future;
use std::pin::Pin;

use crate::protocol::{EventFilter, PortEvent, PortReply, PortRequest};

use super::error::TransportError;

/// Connection state of a transport client.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum ConnectionState {
    Connected,
    Disconnected,
}

/// Trait for submitting protocol requests to a runtime.
///
/// InProcessClient is the primary implementation (no serialization, direct enum pass-through).
pub trait RuntimeClient: Send + Sync + 'static {
    fn request(
        &self,
        req: PortRequest,
    ) -> Pin<Box<dyn Future<Output = Result<PortReply, TransportError>> + Send + '_>>;

    fn request_blocking(&self, req: PortRequest) -> Result<PortReply, TransportError>;

    fn subscribe(
        &self,
        filter: EventFilter,
    ) -> Pin<
        Box<
            dyn Future<Output = Result<tokio::sync::mpsc::Receiver<PortEvent>, TransportError>>
                + Send
                + '_,
        >,
    >;

    fn connection_state(&self) -> ConnectionState;
}