Improve callback docs

Signed-off-by: Tomasz Pietrek <[email protected]>

async-nats/CHANGELOG.md

@@ -2,12 +2,16 @@
 ## Overview
 This release focuses on fixes and improvements, with addition of ordered Push Consumer.
 
+## Breaking Changes
+* Refactor callbacks by @Jarema in https://github.com/nats-io/nats.rs/pull/595
+
 ## Added
 * Add `get_last_raw_message_by_subject` to `Stream` by @caspervonb in https://github.com/nats-io/nats.rs/pull/584
 * Add `ClusterInfo` and `PeerInfo` by @Jarema in https://github.com/nats-io/nats.rs/pull/572
 * Add ordered  push consumer by @Jarema in https://github.com/nats-io/nats.rs/pull/574
 * Add concurrent example by @Jarema in https://github.com/nats-io/nats.rs/pull/580
 * Add delete message from stream by @Jarema in https://github.com/nats-io/nats.rs/pull/588
+* Add Nkey authorization support by @neogenie  https://github.com/nats-io/nats.rs/pull/593
 
 ## Fixed
 * Fix ordered consumer after discard policy hit by @Jarema in https://github.com/nats-io/nats.rs/pull/585

async-nats/src/options.rs

@@ -406,11 +406,29 @@ impl ConnectOptions {
     ///
     /// ## Basic
     /// If you don't need to move anything into the closure, simple signature can be used:
+    ///
     /// ```no_run
     /// # #[tokio::main]
     /// # async fn main() -> std::io::Result<()> {
     /// async_nats::ConnectOptions::new().event_callback(|event| async move {
-    /// println!("event occured: {}", event);
+    ///         println!("event occured: {}", event);
+    /// }).connect("demo.nats.io").await?;
+    /// # Ok(())
+    /// # }
+    ///
+    /// ```
+    ///
+    /// ## Listening to specific event kind
+    /// ```no_run
+    /// # #[tokio::main]
+    /// # async fn main() -> std::io::Result<()> {
+    /// async_nats::ConnectOptions::new().event_callback(|event| async move {
+    ///     match event {
+    ///     async_nats::Event::Disconnect => println!("disconnected"),
+    ///         async_nats::Event::Reconnect => println!("reconnected"),
+    ///         async_nats::Event::ClientError(err) => println!("client error occured: {}", err),
+    ///         other => println!("other event happened: {}", other),
+    /// }
     /// }).connect("demo.nats.io").await?;
     /// # Ok(())
     /// # }
@@ -419,7 +437,7 @@ impl ConnectOptions {
     /// ## Advanced
     /// If you need to move something into the closure, here's an example how to do that
     ///
-    /// ```
+    /// ```no_run
     /// # #[tokio::main]
     /// # async fn main() -> std::result::Result<(), Box<dyn std::error::Error>> {
     /// let (tx, mut _rx) = tokio::sync::mpsc::channel(1);