Add Vec to ToServerAddrs impl and improve docs examples

.config/nats.dic

@@ -119,3 +119,5 @@ cloneable
 PurgeRequest
 StatsResponse
 SemVer
+ServerAddr
+Vec

async-nats/src/lib.rs

@@ -760,6 +760,8 @@ impl fmt::Display for Event {
 /// To have customized NATS connection, check [ConnectOptions].
 ///
 /// # Examples
+///
+/// ## Single URL
 /// ```
 /// # #[tokio::main]
 /// # async fn main() ->  Result<(), async_nats::Error> {
@@ -768,6 +770,56 @@ impl fmt::Display for Event {
 /// # Ok(())
 /// # }
 /// ```
+///
+/// ## Connect with [Vec] of [ServerAddr].
+/// ```no_run
+///#[tokio::main]
+///# async fn main() -> Result<(), async_nats::Error> {
+///use async_nats::ServerAddr;
+///let client = async_nats::connect(vec![
+///    "demo.nats.io".parse::<ServerAddr>()?,
+///    "other.nats.io".parse::<ServerAddr>()?,
+///])
+///.await
+///.unwrap();
+///# Ok(())
+///# }
+/// ```
+///
+/// ## with [Vec], but parse URLs inside [crate::connect()]
+/// ```no_run
+///#[tokio::main]
+///# async fn main() -> Result<(), async_nats::Error> {
+///use async_nats::ServerAddr;
+///let servers = vec!["demo.nats.io", "other.nats.io"];
+///let client = async_nats::connect(
+///    servers
+///        .iter()
+///        .map(|url| url.parse())
+///        .collect::<Result<Vec<ServerAddr>, _>>()?
+///)
+///.await?;
+///# Ok(())
+///# }
+///```
+///
+///
+/// ## with slice.
+/// ```no_run
+///#[tokio::main]
+///# async fn main() -> Result<(), async_nats::Error> {
+///use async_nats::ServerAddr;
+///let client = async_nats::connect(
+///    [
+///        "demo.nats.io".parse::<ServerAddr>()?,
+///        "other.nats.io".parse::<ServerAddr>()?,
+///    ]
+///    .as_slice(),
+///)
+///.await?;
+///# Ok(())
+///# }
+///
 pub async fn connect<A: ToServerAddrs>(addrs: A) -> Result<Client, io::Error> {
     connect_with_options(addrs, ConnectOptions::default()).await
 }
@@ -1165,6 +1217,14 @@ impl<'a> ToServerAddrs for &'a [ServerAddr] {
     }
 }
 
+impl ToServerAddrs for Vec<ServerAddr> {
+    type Iter = std::vec::IntoIter<ServerAddr>;
+
+    fn to_server_addrs(&self) -> io::Result<Self::Iter> {
+        Ok(self.clone().into_iter())
+    }
+}
+
 impl<T: ToServerAddrs + ?Sized> ToServerAddrs for &T {
     type Iter = T::Iter;
     fn to_server_addrs(&self) -> io::Result<Self::Iter> {

async-nats/src/options.rs

@@ -138,6 +138,21 @@ impl ConnectOptions {
     /// # Ok(())
     /// # }
     /// ```
+    ///
+    /// ## Pass multiple URLs.
+    /// ```no_run
+    ///#[tokio::main]
+    ///# async fn main() -> Result<(), async_nats::Error> {
+    ///use async_nats::ServerAddr;
+    ///let client = async_nats::connect(vec![
+    ///    "demo.nats.io".parse::<ServerAddr>()?,
+    ///    "other.nats.io".parse::<ServerAddr>()?,
+    ///])
+    ///.await
+    ///.unwrap();
+    ///# Ok(())
+    ///# }
+    /// ```
     pub async fn connect<A: ToServerAddrs>(self, addrs: A) -> io::Result<Client> {
         crate::connect_with_options(addrs, self).await
     }