reduce ContentSource::get resolve tasks

crates/turbopack-dev-server/src/source/combined.rs

@@ -102,8 +102,12 @@ impl PausableCombinedContentSource {
             // we've skipped to exactly the source which requested data. Requery the source
             // with it's partially computed path and needed data.
             let result = match pending.take() {
-                Some(pending) => pending.source.get(&pending.path, mem::take(&mut data)),
-                None => source.get(path, Default::default()),
+                Some(pending) => pending
+                    .source
+                    .resolve()
+                    .await?
+                    .get(&pending.path, mem::take(&mut data)),
+                None => source.resolve().await?.get(path, Default::default()),
             };
 
             let res = result.await?;

crates/turbopack-dev-server/src/source/resolve.rs

@@ -77,7 +77,7 @@ pub async fn resolve_source_request(
                         let new_asset_path =
                             urlencoding::decode(&new_uri.path()[1..])?.into_owned();
 
-                        current_source = new_source;
+                        current_source = new_source.resolve().await?;
                         request_overwrites.uri = new_uri;
                         current_asset_path = new_asset_path;
                         data = ContentSourceData::default();

crates/turbopack-dev-server/src/source/router.rs

@@ -28,9 +28,13 @@ impl RouterContentSource {
 #[turbo_tasks::value_impl]
 impl ContentSource for RouterContentSource {
     #[turbo_tasks::function]
-    fn get(&self, path: &str, data: Value<ContentSourceData>) -> ContentSourceResultVc {
+    async fn get(
+        &self,
+        path: &str,
+        data: Value<ContentSourceData>,
+    ) -> Result<ContentSourceResultVc> {
         let (source, path) = self.get_source(path);
-        source.get(path, data)
+        Ok(source.resolve().await?.get(path, data))
     }
 
     #[turbo_tasks::function]