Modify Worker::connect to use the password in the URL, as Client::con…

…nect does. (#73)
jonhoo · Jul 20, 2024 · 5c0ff09 · 5c0ff09
1 parent 159e840
commit 5c0ff09
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/worker/builder.rs b/src/worker/builder.rs
@@ -183,6 +183,7 @@ impl<E: 'static> WorkerBuilder<E> {
     ) -> Result<Worker<BufStream<TokioStream>, E>, Error> {
         let url = utils::parse_provided_or_from_env(url)?;
         let stream = TokioStream::connect(utils::host_from_url(&url)).await?;
-        self.connect_with(stream, None).await
+        self.connect_with(stream, url.password().map(|p| p.to_string()))
+            .await
     }
 }