Initialize dispatcher for livekit

crates/live_kit_client/Cargo.toml

@@ -32,7 +32,7 @@ async-broadcast = "0.7"
 async-trait = { workspace = true, optional = true }
 collections = { workspace = true, optional = true }
 futures.workspace = true
-gpui = { workspace = true, optional = true }
+gpui.workspace = true
 livekit.workspace = true
 live_kit_server = { workspace = true, optional = true }
 log.workspace = true

crates/live_kit_client/build.rs

@@ -0,0 +1,3 @@
+fn main() {
+    println!("cargo:rustc-link-arg=-Objc");
+}

crates/live_kit_client/examples/test_app.rs

@@ -16,6 +16,8 @@ fn main() {
     SimpleLogger::init(LevelFilter::Info, Default::default()).expect("could not initialize logger");
 
     gpui::App::new().run(|cx| {
+        live_kit_client::init(cx.background_executor().dispatcher.clone());
+
         #[cfg(any(test, feature = "test-support"))]
         println!("USING TEST LIVEKIT");
 

crates/live_kit_client/src/live_kit_client.rs

@@ -1,6 +1,8 @@
+use std::sync::Arc;
+
 use anyhow::Result;
 use futures::{Stream, StreamExt as _};
-use gpui::{ScreenCaptureFrame, ScreenCaptureSource, ScreenCaptureStream};
+use gpui::{AppContext, ScreenCaptureFrame, ScreenCaptureSource, ScreenCaptureStream};
 use webrtc::{
     audio_source::{native::NativeAudioSource, AudioSourceOptions, RtcAudioSource},
     video_frame::{native::NativeBuffer, VideoFrame, VideoRotation},
@@ -16,6 +18,26 @@ pub mod test;
 #[cfg(any(test, feature = "test-support"))]
 pub use test::*;
 
+pub fn init(dispatcher: Arc<dyn gpui::PlatformDispatcher>) {
+    struct Dispatcher(Arc<dyn gpui::PlatformDispatcher>);
+
+    impl livekit::dispatcher::Dispatcher for Dispatcher {
+        fn dispatch(&self, runnable: livekit::dispatcher::Runnable) {
+            self.0.dispatch(runnable, None);
+        }
+
+        fn dispatch_after(
+            &self,
+            duration: std::time::Duration,
+            runnable: livekit::dispatcher::Runnable,
+        ) {
+            self.0.dispatch_after(duration, runnable);
+        }
+    }
+
+    livekit::dispatcher::set_dispatcher(Dispatcher(dispatcher));
+}
+
 pub async fn create_video_track_from_screen_capture_source(
     capture_source: &dyn ScreenCaptureSource,
 ) -> Result<(track::LocalVideoTrack, Box<dyn ScreenCaptureStream>)> {