From a4302cadeb28b3531ba56e4020f043cdc6920c72 Mon Sep 17 00:00:00 2001
From: Maximilian Ammann <max@maxammann.org>
Date: Wed, 4 May 2022 18:51:19 +0200
Subject: [PATCH 1/6] Use only non-send futures

---
 maplibre/Cargo.toml                           |  2 +-
 maplibre/src/io/scheduler.rs                  | 10 ----------
 maplibre/src/io/source_client.rs              |  6 +-----
 maplibre/src/platform/noweb/http_client.rs    |  2 +-
 .../src/platform/noweb/schedule_method.rs     | 20 ++++++++++++++-----
 web/Cargo.toml                                |  2 +-
 6 files changed, 19 insertions(+), 23 deletions(-)

diff --git a/maplibre/Cargo.toml b/maplibre/Cargo.toml
index d5578e485..dc321a2a5 100644
--- a/maplibre/Cargo.toml
+++ b/maplibre/Cargo.toml
@@ -12,7 +12,6 @@ readme = "../README.md"
 web-webgl = ["wgpu/webgl"]
 # Enable tracing using tracy on desktop/mobile and the chrome profiler on web
 enable-tracing = [ "tracing-subscriber", "tracing-tracy", "tracy-client"]
-no-thread-safe-futures = []
 
 [target.'cfg(target_arch = "wasm32")'.dependencies]
 web-sys = { version = "0.3", features = [
@@ -23,6 +22,7 @@ wasm-bindgen-futures = "0.4"
 
 [target.'cfg(any(target_os = "macos", target_os = "ios", target_os = "linux", target_os = "android"))'.dependencies]
 tokio = { version = "1.17", features = ["macros", "rt", "rt-multi-thread", "sync", "time"] }
+tokio-util = { version = "0.7.1", features = ["rt"] }
 env_logger = "0.9"
 reqwest = { version = "0.11", default-features = false, features = ["rustls-tls", "gzip"] }
 reqwest-middleware-cache = "0.1" # FIXME: Untrusted dependency
diff --git a/maplibre/src/io/scheduler.rs b/maplibre/src/io/scheduler.rs
index 972d62a38..13e4e31c5 100644
--- a/maplibre/src/io/scheduler.rs
+++ b/maplibre/src/io/scheduler.rs
@@ -25,16 +25,6 @@ where
 }
 
 pub trait ScheduleMethod: 'static {
-    #[cfg(not(feature = "no-thread-safe-futures"))]
-    fn schedule<T>(
-        &self,
-        shared_thread_state: SharedThreadState,
-        future_factory: impl (FnOnce(SharedThreadState) -> T) + Send + 'static,
-    ) -> Result<(), Error>
-    where
-        T: Future<Output = ()> + Send + 'static;
-
-    #[cfg(feature = "no-thread-safe-futures")]
     fn schedule<T>(
         &self,
         shared_thread_state: SharedThreadState,
diff --git a/maplibre/src/io/source_client.rs b/maplibre/src/io/source_client.rs
index ceaaf62af..3c10bf4e9 100644
--- a/maplibre/src/io/source_client.rs
+++ b/maplibre/src/io/source_client.rs
@@ -8,11 +8,7 @@ pub type HTTPClientFactory<HC> = dyn Fn() -> HC;
 // On the web platform futures are not thread-safe (i.e. not Send). This means we need to tell
 // async_trait that these bounds should not be placed on the async trait:
 // https://github.com/dtolnay/async-trait/blob/b70720c4c1cc0d810b7446efda44f81310ee7bf2/README.md#non-threadsafe-futures
-//
-// Users of this library can decide whether futures from the HTTPClient are thread-safe or not via
-// the future "no-thread-safe-futures". Tokio futures are thread-safe.
-#[cfg_attr(feature = "no-thread-safe-futures", async_trait(?Send))]
-#[cfg_attr(not(feature = "no-thread-safe-futures"), async_trait)]
+#[async_trait(?Send)]
 pub trait HTTPClient: Clone + Sync + Send + 'static {
     async fn fetch(&self, url: &str) -> Result<Vec<u8>, Error>;
 }
diff --git a/maplibre/src/platform/noweb/http_client.rs b/maplibre/src/platform/noweb/http_client.rs
index aa2d43c6e..818fe4a6b 100644
--- a/maplibre/src/platform/noweb/http_client.rs
+++ b/maplibre/src/platform/noweb/http_client.rs
@@ -40,7 +40,7 @@ impl ReqwestHttpClient {
     }
 }
 
-#[async_trait]
+#[async_trait(?Send)]
 impl HTTPClient for ReqwestHttpClient {
     async fn fetch(&self, url: &str) -> Result<Vec<u8>, Error> {
         let response = self.client.get(url).send().await?;
diff --git a/maplibre/src/platform/noweb/schedule_method.rs b/maplibre/src/platform/noweb/schedule_method.rs
index fd55cfa88..75a27c93c 100644
--- a/maplibre/src/platform/noweb/schedule_method.rs
+++ b/maplibre/src/platform/noweb/schedule_method.rs
@@ -2,12 +2,17 @@ use crate::error::Error;
 use crate::io::shared_thread_state::SharedThreadState;
 use crate::ScheduleMethod;
 use std::future::Future;
-
-pub struct TokioScheduleMethod;
+use tokio::task;
+use tokio_util::task::LocalPoolHandle;
+pub struct TokioScheduleMethod {
+    pool: LocalPoolHandle,
+}
 
 impl TokioScheduleMethod {
     pub fn new() -> Self {
-        Self {}
+        Self {
+            pool: LocalPoolHandle::new(4),
+        }
     }
 }
 
@@ -18,9 +23,14 @@ impl ScheduleMethod for TokioScheduleMethod {
         future_factory: impl FnOnce(SharedThreadState) -> T + Send + 'static,
     ) -> Result<(), Error>
     where
-        T: Future<Output = ()> + Send + 'static,
+        T: Future<Output = ()> + 'static,
     {
-        tokio::task::spawn(future_factory(shared_thread_state));
+        self.pool.spawn_pinned(|| {
+            let unsend_data = (future_factory)(shared_thread_state);
+
+            async move { unsend_data.await }
+        });
+
         Ok(())
     }
 }
diff --git a/web/Cargo.toml b/web/Cargo.toml
index 5d2417a01..201a2ff76 100644
--- a/web/Cargo.toml
+++ b/web/Cargo.toml
@@ -19,7 +19,7 @@ crate-type = ["cdylib", "rlib"]
 
 [dependencies]
 async-trait = "0.1"
-maplibre = { path = "../maplibre", features = ["no-thread-safe-futures"] }
+maplibre = { path = "../maplibre", features = [] }
 winit = "*"
 log = "*"
 

From f42c0b5e509f591a6a645c4f39039652b6373c47 Mon Sep 17 00:00:00 2001
From: Maximilian Ammann <max@maxammann.org>
Date: Tue, 10 May 2022 09:19:49 +0200
Subject: [PATCH 2/6] Fix merge

---
 web/Cargo.toml | 1 -
 1 file changed, 1 deletion(-)

diff --git a/web/Cargo.toml b/web/Cargo.toml
index 3c9cd7cb8..2ca59ddab 100644
--- a/web/Cargo.toml
+++ b/web/Cargo.toml
@@ -20,7 +20,6 @@ crate-type = ["cdylib", "rlib"]
 [dependencies]
 async-trait = "0.1"
 maplibre = { path = "../maplibre", features = [] }
-maplibre = { path = "../maplibre", features = ["no-thread-safe-futures"] }
 maplibre-winit = { path = "../maplibre-winit", version = "0.0.1"  }
 log = "0.4"
 

From 75c069e04eed03f092e7d96540522601eb858b1b Mon Sep 17 00:00:00 2001
From: Maximilian Ammann <max@maxammann.org>
Date: Sun, 17 Jul 2022 21:20:38 +0200
Subject: [PATCH 3/6] Fix formatting

---
 maplibre/src/platform/noweb/schedule_method.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/maplibre/src/platform/noweb/schedule_method.rs b/maplibre/src/platform/noweb/schedule_method.rs
index 9f91fae50..20672a5b4 100644
--- a/maplibre/src/platform/noweb/schedule_method.rs
+++ b/maplibre/src/platform/noweb/schedule_method.rs
@@ -1,4 +1,5 @@
 use std::future::Future;
+
 use tokio::task;
 use tokio_util::task::LocalPoolHandle;
 

From 2a48027be11395dc6b75c1a5472eda58eb2a62ba Mon Sep 17 00:00:00 2001
From: Maximilian Ammann <max@maxammann.org>
Date: Thu, 5 Oct 2023 20:41:00 +0100
Subject: [PATCH 4/6] Fixes after merge

---
 .idea/runConfigurations/Run_demo__debug_.xml |  2 +-
 android/Cargo.toml                           |  2 +-
 apple/Cargo.toml                             |  2 +-
 benchmarks/Cargo.toml                        |  2 +-
 maplibre-demo/Cargo.toml                     |  2 +-
 maplibre-winit/src/lib.rs                    |  6 +--
 maplibre-winit/src/noweb.rs                  |  6 +--
 maplibre/Cargo.toml                          |  3 +-
 maplibre/src/environment.rs                  |  4 +-
 maplibre/src/io/apc.rs                       | 12 ++----
 maplibre/src/io/scheduler.rs                 |  2 +-
 maplibre/src/platform/noweb/scheduler.rs     | 39 +++++++++-----------
 12 files changed, 37 insertions(+), 45 deletions(-)

diff --git a/.idea/runConfigurations/Run_demo__debug_.xml b/.idea/runConfigurations/Run_demo__debug_.xml
index 8c5fa36e3..3ded76bf0 100644
--- a/.idea/runConfigurations/Run_demo__debug_.xml
+++ b/.idea/runConfigurations/Run_demo__debug_.xml
@@ -2,10 +2,10 @@
   <configuration default="false" name="Run demo (debug)" type="CargoCommandRunConfiguration" factoryName="Cargo Command">
     <option name="command" value="run -p maplibre-demo -- headed" />
     <option name="workingDirectory" value="file://$PROJECT_DIR$" />
+    <option name="emulateTerminal" value="false" />
     <option name="channel" value="DEFAULT" />
     <option name="requiredFeatures" value="true" />
     <option name="allFeatures" value="false" />
-    <option name="emulateTerminal" value="false" />
     <option name="withSudo" value="false" />
     <option name="buildTarget" value="REMOTE" />
     <option name="backtrace" value="SHORT" />
diff --git a/android/Cargo.toml b/android/Cargo.toml
index 80285bba7..61f3911da 100644
--- a/android/Cargo.toml
+++ b/android/Cargo.toml
@@ -12,7 +12,7 @@ categories.workspace = true
 authors.workspace = true
 
 [dependencies]
-maplibre = { path = "../maplibre", features = ["thread-safe-futures"] }
+maplibre = { path = "../maplibre", features = [] }
 maplibre-winit = { path = "../maplibre-winit", version = "0.1.0"  }
 env_logger.workspace = true
 log.workspace = true
diff --git a/apple/Cargo.toml b/apple/Cargo.toml
index 941d74bef..615d9c0c2 100644
--- a/apple/Cargo.toml
+++ b/apple/Cargo.toml
@@ -12,7 +12,7 @@ categories.workspace = true
 authors.workspace = true
 
 [dependencies]
-maplibre = { path = "../maplibre", features = ["thread-safe-futures"] }
+maplibre = { path = "../maplibre", features = [] }
 maplibre-winit = { path = "../maplibre-winit", version = "0.1.0"  }
 
 env_logger.workspace = true
diff --git a/benchmarks/Cargo.toml b/benchmarks/Cargo.toml
index 94354988e..6225531a6 100644
--- a/benchmarks/Cargo.toml
+++ b/benchmarks/Cargo.toml
@@ -12,7 +12,7 @@ categories.workspace = true
 authors.workspace = true
 
 [dependencies]
-maplibre = { path = "../maplibre", features = ["headless", "embed-static-tiles", "thread-safe-futures"] }
+maplibre = { path = "../maplibre", features = ["headless", "embed-static-tiles"] }
 
 [dev-dependencies]
 criterion.workspace = true
diff --git a/maplibre-demo/Cargo.toml b/maplibre-demo/Cargo.toml
index 77f8bf831..19e3d5339 100644
--- a/maplibre-demo/Cargo.toml
+++ b/maplibre-demo/Cargo.toml
@@ -18,7 +18,7 @@ headless = ["maplibre/headless"]
 
 [dependencies]
 env_logger.workspace = true
-maplibre = { path = "../maplibre", version = "0.1.0", features = ["thread-safe-futures"]  }
+maplibre = { path = "../maplibre", version = "0.1.0", features = []  }
 maplibre-winit = { path = "../maplibre-winit", version = "0.1.0"  }
 tile-grid.workspace = true
 clap.workspace = true
diff --git a/maplibre-winit/src/lib.rs b/maplibre-winit/src/lib.rs
index 2a33b4718..8ac42828a 100644
--- a/maplibre-winit/src/lib.rs
+++ b/maplibre-winit/src/lib.rs
@@ -6,7 +6,7 @@ use instant::Instant;
 use maplibre::{
     environment::{Environment, OffscreenKernelEnvironment},
     event_loop::{EventLoop, EventLoopProxy, SendEventError},
-    io::{apc::AsyncProcedureCall, scheduler::Scheduler, source_client::HttpClient},
+    io::{apc::AsyncProcedureCall, scheduler::ScheduleMethod, source_client::HttpClient},
     map::Map,
     window::{HeadedMapWindow, MapWindowConfig},
 };
@@ -191,7 +191,7 @@ impl<ET: 'static> EventLoopProxy<ET> for WinitEventLoopProxy<ET> {
 }
 
 pub struct WinitEnvironment<
-    S: Scheduler,
+    S: ScheduleMethod,
     HC: HttpClient,
     K: OffscreenKernelEnvironment,
     APC: AsyncProcedureCall<K>,
@@ -205,7 +205,7 @@ pub struct WinitEnvironment<
 }
 
 impl<
-        S: Scheduler,
+        S: ScheduleMethod,
         HC: HttpClient,
         K: OffscreenKernelEnvironment,
         APC: AsyncProcedureCall<K>,
diff --git a/maplibre-winit/src/noweb.rs b/maplibre-winit/src/noweb.rs
index 94cdd0f99..4c82e60a6 100644
--- a/maplibre-winit/src/noweb.rs
+++ b/maplibre-winit/src/noweb.rs
@@ -12,7 +12,7 @@ use maplibre::{
     kernel::{Kernel, KernelBuilder},
     map::Map,
     platform::{
-        http_client::ReqwestHttpClient, run_multithreaded, scheduler::TokioScheduler,
+        http_client::ReqwestHttpClient, run_multithreaded, scheduler::TokioScheduleMethod,
         ReqwestOffscreenKernelEnvironment,
     },
     raster::{DefaultRasterTransferables, RasterPlugin},
@@ -114,8 +114,8 @@ pub fn run_headed_map(
         let kernel: Kernel<Environment<_, _, _>> = KernelBuilder::new()
             .with_map_window_config(window_config)
             .with_http_client(client.clone())
-            .with_apc(SchedulerAsyncProcedureCall::new(TokioScheduler::new()))
-            .with_scheduler(TokioScheduler::new())
+            .with_apc(SchedulerAsyncProcedureCall::new(TokioScheduleMethod::new()))
+            .with_scheduler(TokioScheduleMethod::new())
             .build();
 
         let renderer_builder = RendererBuilder::new().with_wgpu_settings(wgpu_settings);
diff --git a/maplibre/Cargo.toml b/maplibre/Cargo.toml
index c5fb5391b..03ef90af7 100644
--- a/maplibre/Cargo.toml
+++ b/maplibre/Cargo.toml
@@ -17,7 +17,7 @@ authors.workspace = true
 default = ["raster"]
 web-webgl = ["wgpu/webgl"]
 # Enable tracing using tracy on desktop/mobile and the chrome profiler on web
-trace = ["tracing-subscriber", "tracing-tracy", "tracy-client"]
+trace = ["tracing-subscriber", "tracing-tracy"]
 embed-static-tiles = ["maplibre-build-tools/sqlite"]
 headless = ["png"]
 raster = ["image"]
@@ -26,7 +26,6 @@ raster = ["image"]
 [target.'cfg(any(target_os = "macos", target_os = "ios", target_os = "linux", target_os = "android", target_os = "windows"))'.dependencies]
 tokio = { workspace = true, features = ["macros", "rt", "rt-multi-thread", "sync", "time"] }
 tokio-util.workspace = true
-tokio-util = { version = "0.7.1", features = ["rt"] }
 env_logger.workspace = true
 reqwest.workspace = true
 reqwest-middleware-cache.workspace = true
diff --git a/maplibre/src/environment.rs b/maplibre/src/environment.rs
index 7f966b93c..f4a66c0e6 100644
--- a/maplibre/src/environment.rs
+++ b/maplibre/src/environment.rs
@@ -1,7 +1,7 @@
 use crate::{
     io::{
         apc::AsyncProcedureCall,
-        scheduler::Scheduler,
+        scheduler::ScheduleMethod,
         source_client::{HttpClient, SourceClient},
     },
     window::MapWindowConfig,
@@ -20,7 +20,7 @@ pub trait Environment: 'static {
 
     type AsyncProcedureCall: AsyncProcedureCall<Self::OffscreenKernelEnvironment>;
 
-    type Scheduler: Scheduler;
+    type Scheduler: ScheduleMethod;
 
     type HttpClient: HttpClient;
 
diff --git a/maplibre/src/io/apc.rs b/maplibre/src/io/apc.rs
index dfeba5e97..b041634ad 100644
--- a/maplibre/src/io/apc.rs
+++ b/maplibre/src/io/apc.rs
@@ -17,7 +17,7 @@ use thiserror::Error;
 
 use crate::{
     coords::WorldTileCoords, define_label, environment::OffscreenKernelEnvironment,
-    io::scheduler::Scheduler, style::Style,
+    io::scheduler::ScheduleMethod, style::Style,
 };
 
 define_label!(MessageTag);
@@ -99,10 +99,6 @@ pub enum ProcedureError {
     Send(SendError),
 }
 
-#[cfg(feature = "thread-safe-futures")]
-pub type AsyncProcedureFuture =
-    Pin<Box<(dyn Future<Output = Result<(), ProcedureError>> + Send + 'static)>>;
-#[cfg(not(feature = "thread-safe-futures"))]
 pub type AsyncProcedureFuture =
     Pin<Box<(dyn Future<Output = Result<(), ProcedureError>> + 'static)>>;
 
@@ -194,14 +190,14 @@ impl Context for SchedulerContext {
     }
 }
 
-pub struct SchedulerAsyncProcedureCall<K: OffscreenKernelEnvironment, S: Scheduler> {
+pub struct SchedulerAsyncProcedureCall<K: OffscreenKernelEnvironment, S: ScheduleMethod> {
     channel: (Sender<Message>, Receiver<Message>),
     buffer: RefCell<Vec<Message>>,
     scheduler: S,
     phantom_k: PhantomData<K>,
 }
 
-impl<K: OffscreenKernelEnvironment, S: Scheduler> SchedulerAsyncProcedureCall<K, S> {
+impl<K: OffscreenKernelEnvironment, S: ScheduleMethod> SchedulerAsyncProcedureCall<K, S> {
     pub fn new(scheduler: S) -> Self {
         Self {
             channel: mpsc::channel(),
@@ -212,7 +208,7 @@ impl<K: OffscreenKernelEnvironment, S: Scheduler> SchedulerAsyncProcedureCall<K,
     }
 }
 
-impl<K: OffscreenKernelEnvironment, S: Scheduler> AsyncProcedureCall<K>
+impl<K: OffscreenKernelEnvironment, S: ScheduleMethod> AsyncProcedureCall<K>
     for SchedulerAsyncProcedureCall<K, S>
 {
     type Context = SchedulerContext;
diff --git a/maplibre/src/io/scheduler.rs b/maplibre/src/io/scheduler.rs
index ae51e35a5..3143c0c40 100644
--- a/maplibre/src/io/scheduler.rs
+++ b/maplibre/src/io/scheduler.rs
@@ -25,7 +25,7 @@ pub trait ScheduleMethod: 'static {
 
 pub struct NopScheduler;
 
-impl Scheduler for NopScheduler {
+impl ScheduleMethod for NopScheduler {
     fn schedule<T>(
         &self,
         _future_factory: impl FnOnce() -> T + Send + 'static,
diff --git a/maplibre/src/platform/noweb/scheduler.rs b/maplibre/src/platform/noweb/scheduler.rs
index 0d7a249d0..48a77d22b 100644
--- a/maplibre/src/platform/noweb/scheduler.rs
+++ b/maplibre/src/platform/noweb/scheduler.rs
@@ -1,43 +1,40 @@
 use std::future::Future;
 
-use crate::io::scheduler::{ScheduleError, Scheduler};
+use tokio_util::task::LocalPoolHandle;
+
+use crate::io::scheduler::{ScheduleError, ScheduleMethod};
 
 /// Multi-threading with Tokio.
-pub struct TokioScheduler;
+pub struct TokioScheduleMethod {
+    pool: LocalPoolHandle,
+}
 
-impl TokioScheduler {
+impl TokioScheduleMethod {
     pub fn new() -> Self {
-        Self {}
+        Self {
+            pool: LocalPoolHandle::new(4),
+        }
     }
 }
 
-impl Scheduler for TokioScheduler {
-    #[cfg(feature = "thread-safe-futures")]
+impl ScheduleMethod for TokioScheduleMethod {
     fn schedule<T>(
         &self,
-        future_factory: impl FnOnce() -> T + Send + 'static,
-    ) -> Result<(), ScheduleError>
-    where
-        T: Future<Output = ()> + Send + 'static,
-    {
-        tokio::task::spawn((future_factory)());
-        Ok(())
-    }
-
-    // FIXME: Provide a working implementation
-    #[cfg(not(feature = "thread-safe-futures"))]
-    fn schedule<T>(
-        &self,
-        _future_factory: impl FnOnce() -> T + 'static,
+        future_factory: impl FnOnce() -> T + 'static + Send,
     ) -> Result<(), ScheduleError>
     where
         T: Future<Output = ()> + 'static,
     {
+        self.pool.spawn_pinned(|| {
+            let unsend_data = (future_factory)();
+
+            async move { unsend_data.await }
+        });
         Ok(())
     }
 }
 
-impl Default for TokioScheduler {
+impl Default for TokioScheduleMethod {
     fn default() -> Self {
         Self::new()
     }

From 50829771f40978412ae1a09ba60e0edf8efa00c0 Mon Sep 17 00:00:00 2001
From: Maximilian Ammann <max@maxammann.org>
Date: Mon, 9 Oct 2023 17:48:14 +0100
Subject: [PATCH 5/6] Fix compilation

---
 maplibre/src/headless/environment.rs | 4 ++--
 maplibre/src/headless/mod.rs         | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/maplibre/src/headless/environment.rs b/maplibre/src/headless/environment.rs
index bf2c6dfb2..e34e287dd 100644
--- a/maplibre/src/headless/environment.rs
+++ b/maplibre/src/headless/environment.rs
@@ -3,7 +3,7 @@ use crate::{
     headless::window::HeadlessMapWindowConfig,
     io::apc::SchedulerAsyncProcedureCall,
     platform::{
-        http_client::ReqwestHttpClient, scheduler::TokioScheduler,
+        http_client::ReqwestHttpClient, scheduler::TokioScheduleMethod,
         ReqwestOffscreenKernelEnvironment,
     },
 };
@@ -14,7 +14,7 @@ impl Environment for HeadlessEnvironment {
     type MapWindowConfig = HeadlessMapWindowConfig;
     type AsyncProcedureCall =
         SchedulerAsyncProcedureCall<Self::OffscreenKernelEnvironment, Self::Scheduler>;
-    type Scheduler = TokioScheduler;
+    type Scheduler = TokioScheduleMethod;
     type HttpClient = ReqwestHttpClient;
     type OffscreenKernelEnvironment = ReqwestOffscreenKernelEnvironment;
 }
diff --git a/maplibre/src/headless/mod.rs b/maplibre/src/headless/mod.rs
index fd679e68f..3a0cbbaa2 100644
--- a/maplibre/src/headless/mod.rs
+++ b/maplibre/src/headless/mod.rs
@@ -9,7 +9,7 @@ use crate::{
     },
     io::apc::SchedulerAsyncProcedureCall,
     kernel::{Kernel, KernelBuilder},
-    platform::{http_client::ReqwestHttpClient, scheduler::TokioScheduler},
+    platform::{http_client::ReqwestHttpClient, scheduler::TokioScheduleMethod},
     plugin::Plugin,
     render::{
         builder::RendererBuilder, graph::RenderGraph, tile_view_pattern::ViewTileSources,
@@ -37,8 +37,8 @@ pub async fn create_headless_renderer(
             WindowSize::new(tile_size, tile_size).unwrap(),
         ))
         .with_http_client(client.clone())
-        .with_apc(SchedulerAsyncProcedureCall::new(TokioScheduler::new()))
-        .with_scheduler(TokioScheduler::new())
+        .with_apc(SchedulerAsyncProcedureCall::new(TokioScheduleMethod::new()))
+        .with_scheduler(TokioScheduleMethod::new())
         .build();
 
     let mwc: &HeadlessMapWindowConfig = kernel.map_window_config();

From 77304f340096f67865565af4b104047751e3a303 Mon Sep 17 00:00:00 2001
From: Maximilian Ammann <max@maxammann.org>
Date: Mon, 9 Oct 2023 18:00:05 +0100
Subject: [PATCH 6/6] Fix compilation

---
 web/src/platform/multithreaded/pool_scheduler.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/web/src/platform/multithreaded/pool_scheduler.rs b/web/src/platform/multithreaded/pool_scheduler.rs
index b36d396ef..1cebe9b50 100644
--- a/web/src/platform/multithreaded/pool_scheduler.rs
+++ b/web/src/platform/multithreaded/pool_scheduler.rs
@@ -1,6 +1,6 @@
 use std::future::Future;
 
-use maplibre::{benchmarking::io::scheduler::ScheduleError, io::scheduler::Scheduler};
+use maplibre::{benchmarking::io::scheduler::ScheduleError, io::scheduler::ScheduleMethod};
 use wasm_bindgen::{prelude::*, JsCast};
 use web_sys::Worker;
 
@@ -27,7 +27,7 @@ impl WebWorkerPoolScheduler {
     }
 }
 
-impl Scheduler for WebWorkerPoolScheduler {
+impl ScheduleMethod for WebWorkerPoolScheduler {
     fn schedule<T>(
         &self,
         future_factory: impl (FnOnce() -> T) + Send + 'static,