AppFlowy/frontend/rust-lib/lib-dispatch/tests/api/module.rs

use lib_dispatch::prelude::*;
use lib_dispatch::runtime::AFPluginRuntime;
use std::sync::Arc;
use tokio::task::LocalSet;

pub async fn hello() -> String {
  "say hello".to_string()
}

#[tokio::test]
async fn test() {
  let event = "1";
  let runtime = Arc::new(AFPluginRuntime::new().unwrap());
  #[allow(clippy::arc_with_non_send_sync)]
  let dispatch = Arc::new(AFPluginDispatcher::new(
    runtime,
    vec![AFPlugin::new().event(event, hello)],
  ));
  let request = AFPluginRequest::new(event);
  let local_set = LocalSet::new();
  local_set
    .run_until(AFPluginDispatcher::async_send_with_callback(
      dispatch.as_ref(),
      request,
      |resp| {
        Box::pin(async move {
          dbg!(&resp);
        })
      },
    ))
    .await;

  std::mem::forget(dispatch);
}