Skip to content

Commit

Permalink
Merge branch 'release/v2.1.2'
Browse files Browse the repository at this point in the history
  • Loading branch information
wallyqs committed Jul 29, 2022
2 parents 391c028 + 161cfc2 commit 51e654c
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions spec/js_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -228,6 +228,7 @@
msg = msgs.first
msg.ack
expect(msg.data).to eql("hello: 2")
sleep 0.5

resp = nc.request("$JS.API.CONSUMER.INFO.test.test")
info = JSON.parse(resp.data, symbolize_names: true)
Expand Down Expand Up @@ -592,6 +593,7 @@
msgs = future.wait_for(1)
expect(msgs.count).to eql(1)

sleep 0.5
info = sub.consumer_info
expect(info.stream_name).to eql("hello")
expect(info.num_pending).to eql(0)
Expand Down Expand Up @@ -619,6 +621,7 @@
expect(info.num_pending).to eql(0)
expect(info.num_ack_pending).to eql(2)
msgs.each { |msg| msg.ack }
sleep 0.5

info = sub.consumer_info
expect(info.num_ack_pending).to eql(0)
Expand Down

0 comments on commit 51e654c

Please sign in to comment.