fix test, update alpha v

streamnative · Jul 10, 2020 · 81d1244 · 81d1244
1 parent 6c5ecb3
commit 81d1244
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "pulsar"
-version = "1.0.0-alpha-3"
+version = "1.0.0-alpha-4"
 edition = "2018"
 authors = [
     "Colin Stearns <[email protected]>",

diff --git a/README.md b/README.md
@@ -50,7 +50,7 @@ async fn main() -> Result<(), pulsar::Error> {
     env_logger::init();
 
     let addr = "pulsar://127.0.0.1:6650";
-    let pulsar: Pulsar<TokioExecutor> = Pulsar::builder(addr).build().await?;
+    let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await?;
     let mut producer = pulsar
         .producer()
         .with_topic("non-persistent://public/default/test")
@@ -108,7 +108,7 @@ async fn main() -> Result<(), pulsar::Error> {
     env_logger::init();
 
     let addr = "pulsar://127.0.0.1:6650";
-    let pulsar: Pulsar<TokioExecutor> = Pulsar::builder(addr).build().await?;
+    let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await?;
 
     let mut consumer: Consumer<TestData, _> = pulsar
         .consumer()

diff --git a/src/lib.rs b/src/lib.rs
@@ -492,7 +492,7 @@ mod tests {
         let addr = "pulsar://127.0.0.1:6650";
         let topic = format!("test_batching_{}", rand::random::<u16>());
 
-        let pulsar: Pulsar<TokioExecutor> = Pulsar::builder(addr).build().await.unwrap();
+        let pulsar: Pulsar<_> = Pulsar::builder(addr, TokioExecutor).build().await.unwrap();
         let mut producer = pulsar.producer()
             .with_topic(&topic)
             .with_options(ProducerOptions {