Async client (unchanged API)

Cargo.toml

@@ -13,7 +13,7 @@ keywords = ["nats", "client", "messaging", "api"]
 categories = ["network-programming", "api-bindings"]
 
 [features]
-fault_injection= []
+fault_injection = []
 
 [badges]
 maintenance = { status = "actively-developed" }
@@ -22,26 +22,32 @@ maintenance = { status = "actively-developed" }
 panic = 'abort'
 
 [dependencies]
-serde = { version = "1.0.106", features = ["derive"] }
-serde_json = "1.0.52"
-regex = "1.3.7"
-nuid = "0.2.1"
-lazy_static = "1.4.0"
-nom = "5.1.1"
+async-channel = "1.1.0"
+async-dup = "1.1.0"
+async-mutex = "1.1.4"
+async-native-tls = "0.3.3"
+base64-url = "1.2.0"
+blocking = "0.4.6"
 crossbeam-channel = "0.4.2"
-parking_lot = "0.10.2"
-rand = "0.7.3"
-native-tls = "0.2.4"
+futures = "0.3.5"
+itoa = "0.4.6"
+lazy_static = "1.4.0"
 log = "0.4.8"
+native-tls = "0.2.4"
 nkeys = "0.0.9"
-base64-url = "1.1.13"
-once_cell = "1.3.1"
+nuid = "0.2.1"
+once_cell = "1.4.0"
+rand = "0.7.3"
+regex = "1.3.9"
+serde = { version = "1.0.114", features = ["derive"] }
+serde_json = "1.0.55"
+smol = "0.1.18"
 
 [dev-dependencies]
 criterion = "0.3.2"
-quicli = "0.4.0"
-structopt = "0.3.14"
 env_logger = "0.7.1"
+quicli = "0.4.0"
+structopt = "0.3.15"
 
 [[bench]]
 name = "nats_bench"

examples/nats_bench.rs

@@ -6,7 +6,6 @@ use std::{
 };
 
 use nats;
-use rand::{thread_rng, Rng};
 use structopt::StructOpt;
 
 /// Simple NATS bench tool
@@ -76,8 +75,7 @@ fn main() -> std::io::Result<()> {
         let nc = nc.clone();
         let subject = args.subject.clone();
         threads.push(thread::spawn(move || {
-            let mut rng = thread_rng();
-            let msg: Vec<u8> = (0..message_size).map(|_| rng.gen::<u8>()).collect();
+            let msg: String = (0..message_size).map(|_| 'a').collect();
             barrier.wait();
             for _ in 0..messages {
                 nc.publish(&subject, &msg).unwrap();