async fn handle_mux_msg(
message_dispatcher: &MessageDispatcher,
subscriptions: &Subscriptions,
msg: Value,
) -> Result<()>async fn handle_mux_msg(
message_dispatcher: &MessageDispatcher,
subscriptions: &Subscriptions,
msg: Value,
) -> Result<()>