Merge pull request #154 from nats-io/tyler_js_consumer

js consumer updates

.github/workflows/test.yml

@@ -94,6 +94,32 @@ jobs:
           rustup update
           cargo test reconnect_test --features=fault_injection -- --ignored
 
+  doctests:
+    name: doctests
+    runs-on: ubuntu-latest
+    steps:
+      - name: Cache Rust
+        uses: actions/cache@v1
+        env:
+          cache-name: cache-rust
+        with:
+          path: target
+          key: ${{ runner.os }}-${{ env.cache-name }}
+          restore-keys: |
+            ${{ runner.os }}-
+      - uses: actions/checkout@v2
+      - uses: actions/setup-go@v2
+        with:
+          go-version: '1.14'
+      - name: install nats-server
+        run: go get github.com/nats-io/nats-server
+      - name: JetStream test
+        env:
+          RUST_LOG: trace
+        run: |
+          rustup update
+          cargo test --doc --features=jetstream
+
   jetstream:
     name: JetStream
     runs-on: ubuntu-latest

CHANGELOG.md

@@ -1,3 +1,12 @@
+# 0.9.6
+
+## New Features
+
+- JetStream consumers are now better supported
+  through the `Consumer::process*` methods,
+  which also perform message deduplication
+  backed by an interval tree.
+
 # 0.9.5
 
 ## New Features

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "nats"
-version = "0.9.5"
+version = "0.9.6"
 description = "A Rust NATS client"
 authors = ["Derek Collison <[email protected]>", "Tyler Neely <[email protected]>", "Stjepan Glavina <[email protected]>"]
 edition = "2018"

async-nats/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "async-nats"
-version = "0.9.5"
+version = "0.9.6"
 description = "An async Rust NATS client"
 authors = ["Derek Collison <[email protected]>", "Tyler Neely <[email protected]>", "Stjepan Glavina <[email protected]>"]
 edition = "2018"
@@ -17,7 +17,7 @@ maintenance = { status = "actively-developed" }
 
 [dependencies]
 blocking = "1.0.2"
-nats = { path = "..", version = "0.9.5" }
+nats = { path = "..", version = "0.9.6" }
 
 [dev-dependencies]
 smol = "1.2.5"

src/client.rs

@@ -619,6 +619,7 @@ impl Client {
                             data: payload,
                             headers: None,
                             client: self.clone(),
+                            double_acked: Default::default(),
                         };
 
                         // Send a message or drop it if the channel is
@@ -642,6 +643,7 @@ impl Client {
                             data: payload,
                             headers: Some(headers),
                             client: self.clone(),
+                            double_acked: Default::default(),
                         };
 
                         // Send a message or drop it if the channel is