Jetstream example isn't working about nats-pure.rb HOT 14 CLOSED

  1) Client - Reconnect should reconnect to server and replay all subscriptions
     Failure/Error: expect(disconnects).to eql(1)

       expected: 1
            got: 0

       (compared using eql?)
     # ./spec/client_reconnect_spec.rb:116:in `block (2 levels) in <top (required)>'

  2) Client - Reconnect should abort reconnecting if disabled
     Failure/Error: expect(nats.last_error).to be_a(Errno::ECONNRESET)
       expected nil to be a kind of Errno::ECONNRESET
     # ./spec/client_reconnect_spec.rb:179:in `block (2 levels) in <top (required)>'

  3) Client - Reconnect should give up reconnecting if no servers available
     Failure/Error: expect(disconnects.count).to eql(2)

       expected: 2
            got: 0

       (compared using eql?)
     # ./spec/client_reconnect_spec.rb:286:in `block (2 levels) in <top (required)>'

  4) Client - Reconnect against a server which is idle during connect should give up reconnecting if no servers available due to timeout errors during connect
     Failure/Error: expect(disconnects.count).to eql(2)

       expected: 2
            got: 0

       (compared using eql?)
     # ./spec/client_reconnect_spec.rb:353:in `block (3 levels) in <top (required)>'

  5) JetStream Pull Subscribe should pull subscribe and fetch messages
     Failure/Error: expect(msgs.count).to eql(5)

       expected: 5
            got: 6

       (compared using eql?)
     # ./spec/js_spec.rb:296:in `block (3 levels) in <top (required)>'

  6) JetStream Pull Subscribe should account pending data
     Failure/Error: raise NATS::IO::BadSubject if !subject or subject.empty?

     NATS::IO::BadSubject:
       NATS::IO::BadSubject
     # ./lib/nats/io/client.rb:369:in `publish'
     # ./lib/nats/io/jetstream/msg/ack_methods.rb:25:in `ack'
     # ./spec/js_spec.rb:510:in `block (5 levels) in <top (required)>'
     # ./spec/js_spec.rb:509:in `each'
     # ./spec/js_spec.rb:509:in `block (4 levels) in <top (required)>'
     # ./spec/js_spec.rb:507:in `times'
     # ./spec/js_spec.rb:507:in `block (3 levels) in <top (required)>'

Finished in 3 minutes 4.4 seconds (files took 0.22966 seconds to load)
101 examples, 6 failures, 2 pending

Failed examples:

rspec ./spec/client_reconnect_spec.rb:63 # Client - Reconnect should reconnect to server and replay all subscriptions
rspec ./spec/client_reconnect_spec.rb:130 # Client - Reconnect should abort reconnecting if disabled
rspec ./spec/client_reconnect_spec.rb:230 # Client - Reconnect should give up reconnecting if no servers available
rspec ./spec/client_reconnect_spec.rb:313 # Client - Reconnect against a server which is idle during connect should give up reconnecting if no servers available due to timeout errors during connect
rspec ./spec/js_spec.rb:168 # JetStream Pull Subscribe should pull subscribe and fetch messages
rspec ./spec/js_spec.rb:477 # JetStream Pull Subscribe should account pending data

"{\"stream_name\":\"add-consumer-test\",\"config\":{\"durable_name\":\"test-create\",\"ack_policy\":\"explicit\",\"ack_wait\":5000000000,\"max_waiting\":3,\"max_ack_pending\":20}}"

"{\"stream_name\":\"add-consumer-test\",\"config\":{\"name\":null,\"durable_name\":\"test-create\",\"description\":null,\"deliver_policy\":null,\"opt_start_seq\":null,\"opt_start_time\":null,\"ack_policy\":\"explicit\",\"ack_wait\":5000000000,\"max_deliver\":null,\"backoff\":null,\"filter_subject\":null,\"replay_policy\":null,\"rate_limit_bps\":null,\"sample_freq\":null,\"max_waiting\":3,\"max_ack_pending\":20,\"flow_control\":null,\"idle_heartbeat\":null,\"headers_only\":null,\"max_batch\":null,\"max_expires\":null,\"deliver_subject\":null,\"deliver_group\":null,\"inactive_threshold\":null,\"num_replicas\":null,\"mem_storage\":null}}"

NATS::IO::Timeout (nats: timeout):

    def flusher_loop
      [...]
       @flush_queue.pop

require 'nats/client'
nats = NATS.connect('127.0.0.1:4222')
psub = nats.jetstream.pull_subscribe('subject', 'durable_subject')

loop do
  msgs = psub.fetch(1)
  msgs.each do |msg|
    puts msg.inspect
    msg.ack
  end
end

flush queue pop
force-flush
["PUB $JS.API.CONSUMER.MSG.NEXT.SUBSTATION.durable_ensure_agent _INBOX.wsl2NyF0BcliULSmt7Xzq8 32\r\n{\"batch\":1,\"expires\":4999900000}\r\n"]
WAITING ON FLUSH EUEUE

flush queue pop
force-flush
["PONG\r\n"]
WAITING ON FLUSH EUEUE
/gems/ruby-3.0.1/gems/nats-pure-2.2.0/lib/nats/io/js.rb:634:in `fetch': nats: fetch timeout (NATS::IO::Timeout)