2 files changed, 38 insertions, 0 deletions
diff --git a/crates/shirabe/tests/plugin/e2e_http_downloader_test.rs b/crates/shirabe/tests/plugin/e2e_http_downloader_test.rs
index 42471b61..f5fdfa97 100644
--- a/crates/shirabe/tests/plugin/e2e_http_downloader_test.rs
+++ b/crates/shirabe/tests/plugin/e2e_http_downloader_test.rs
@@ -76,6 +76,11 @@ get=ok
 response class=\"Composer\\\\Util\\\\Http\\\\Response\" body=\"{\\\"probe\\\":true,\\\"n\\\":42}\" headers=[]
 getHeader=null
 copy=ok file=\"{\\\"probe\\\":true,\\\"n\\\":42}\"
+add-before-enable=LogicException: You must use the HttpDownloader instance which is part of a Composer\\Loop instance to be able to run async http requests
+add=ok body=\"{\\\"probe\\\":true,\\\"n\\\":42}\"
+add-missing=ok rejected=\"Composer\\\\Downloader\\\\TransportException\"
+addCopy=ok file=\"{\\\"probe\\\":true,\\\"n\\\":42}\"
+countActiveJobs=0 wait=ok
 collect=ok
 ",
         upstream.trace
diff --git a/crates/shirabe/tests/plugin/fixtures/e2e-http-downloader/plugin/src/Plugin.php b/crates/shirabe/tests/plugin/fixtures/e2e-http-downloader/plugin/src/Plugin.php
index 054a47ca..6e91ad00 100644
--- a/crates/shirabe/tests/plugin/fixtures/e2e-http-downloader/plugin/src/Plugin.php
+++ b/crates/shirabe/tests/plugin/fixtures/e2e-http-downloader/plugin/src/Plugin.php
@@ -98,6 +98,39 @@ class Plugin implements PluginInterface, EventSubscriberInterface
             $downloader->copy('file://' . $payload, $target);
         }) . ' file=' . json_encode(@file_get_contents($target));
 
+        // A downloader that is not part of a Loop refuses async requests, so the probe records
+        // both sides of the gate.
+        $lines[] = 'add-before-enable=' . $this->describe(static function () use ($downloader, $payload): void {
+            $downloader->add('file://' . $payload);
+        });
+        $downloader->enableAsync();
+
+        $added = null;
+        $lines[] = 'add=' . $this->describe(static function () use ($downloader, $payload, &$added): void {
+            $downloader->add('file://' . $payload)->then(static function ($result) use (&$added): void {
+                $added = $result;
+            });
+        }) . ' body=' . json_encode($added === null ? null : $added->getBody());
+
+        // A path that cannot exist keeps the rejection reason free of the temporary directory.
+        $rejection = null;
+        $lines[] = 'add-missing=' . $this->describe(static function () use ($downloader, &$rejection): void {
+            $downloader->add('file:///shirabe-probe-missing.json')->then(null, static function ($error) use (&$rejection): void {
+                $rejection = $error;
+            });
+        }) . ' rejected=' . json_encode($rejection === null ? null : \get_class($rejection));
+
+        $lines[] = 'addCopy=' . $this->describe(static function () use ($downloader, $payload): void {
+            $downloader->addCopy('file://' . $payload, getcwd() . '/probe-async-copy.json')->then(null, static function ($error): void {
+                throw $error;
+            });
+        }) . ' file=' . json_encode(@file_get_contents(getcwd() . '/probe-async-copy.json'));
+
+        $lines[] = 'countActiveJobs=' . json_encode($downloader->countActiveJobs())
+            . ' wait=' . $this->describe(static function () use ($downloader): void {
+                $downloader->wait();
+            });
+
         // collect() unsets the response's own properties, so the object is spent afterwards and
         // nothing may read it again.
         $lines[] = 'collect=' . $this->describe(static function () use ($response): void {