mod dispatch;
mod helpers;
mod notifications;
mod server_requests;
use std::sync::Arc;
use anyhow::Result;
use tokio::sync::mpsc;
use crate::app_server::AppServerInbound;
use crate::state::BridgeState;
pub(super) async fn run_app_server_event_loop(
state: Arc<BridgeState>,
inbound_rx: mpsc::UnboundedReceiver<AppServerInbound>,
) {
dispatch::run_app_server_event_loop(state, inbound_rx).await;
}
#[cfg_attr(not(test), allow(dead_code))]
pub(super) async fn handle_app_server_message(
state: &BridgeState,
message: AppServerInbound,
) -> Result<()> {
dispatch::handle_app_server_message(state, message).await
}