Struct InputMethodHandler

pub struct InputMethodHandler { /* private fields */ }

Implementations

impl InputMethodHandler

pub fn new(event_tx: Sender<InputMethodEvent>) -> Self

Examples found in repository

examples/input_method.rs (line 14)

async fn main() {
    // create mpsc channel for interacting with the input_method handler
    let (input_method_msg_tx, mut input_method_msg_rx) = mpsc::channel(128);

    // create mpsc channel for receiving events from the input_method handler
    let (input_method_event_tx, mut input_method_event_rx) = mpsc::channel(128);
    
    // create the handler instance
    let mut input_method_handler = InputMethodHandler::new(input_method_event_tx);


    // start the input_method handler
    let input_method_t = tokio::spawn(async move {
        let _ = input_method_handler.run(input_method_msg_rx).await;
    });

    // receive all input_method events
    let input_method_event_t = tokio::spawn(async move {
        loop {
            let msg = input_method_event_rx.recv().await;
            if msg.is_none() {
                continue;
            }
            println!("received input_method_event event={:?}", msg);
        }
    });

    let _ = input_method_t.await.unwrap();
    let _ = input_method_event_t.await.unwrap();
}

pub async fn run(&mut self, msg_rx: Receiver<InputMethodMessage>)

Examples found in repository

examples/input_method.rs (line 19)

async fn main() {
    // create mpsc channel for interacting with the input_method handler
    let (input_method_msg_tx, mut input_method_msg_rx) = mpsc::channel(128);

    // create mpsc channel for receiving events from the input_method handler
    let (input_method_event_tx, mut input_method_event_rx) = mpsc::channel(128);
    
    // create the handler instance
    let mut input_method_handler = InputMethodHandler::new(input_method_event_tx);


    // start the input_method handler
    let input_method_t = tokio::spawn(async move {
        let _ = input_method_handler.run(input_method_msg_rx).await;
    });

    // receive all input_method events
    let input_method_event_t = tokio::spawn(async move {
        loop {
            let msg = input_method_event_rx.recv().await;
            if msg.is_none() {
                continue;
            }
            println!("received input_method_event event={:?}", msg);
        }
    });

    let _ = input_method_t.await.unwrap();
    let _ = input_method_event_t.await.unwrap();
}