Examples

The examples are intentionally short. They show the API the gem is expected to support without turning each file into a test harness.

Core lifecycle

Source: examples/core_lifecycle.rb

bundle exec ruby examples/core_lifecycle.rb

Shows NatsAsync::Client, explicit start(task:), a subscription callback, one publish, and close in ensure.

Queue group

Source: examples/queue_group.rb

bundle exec ruby examples/queue_group.rb

Shows subscribe(subject, queue:) and drain(timeout:) for a worker-style subscriber.

Request/reply

Source: examples/request_reply.rb

bundle exec ruby examples/request_reply.rb

Shows a service publishing to message.reply, async request callbacks, and a message-oriented request promise with wait.data.

Headers and binary payloads

Source: examples/headers_and_binary.rb

bundle exec ruby examples/headers_and_binary.rb

Shows NATS headers through HPUB / HMSG and byte-preserving payload handling.

JetStream management

Source: examples/jetstream_management.rb

bundle exec ruby examples/jetstream_management.rb

Shows add_stream?, stream_exists?, add_consumer?, and consumer_info.

JetStream publish

Source: examples/jetstream_publish.rb

bundle exec ruby examples/jetstream_publish.rb

Shows js.publish returning a publish acknowledgement with stream and seq.

JetStream pull consumer

Source: examples/jetstream_pull_consumer.rb

bundle exec ruby examples/jetstream_pull_consumer.rb

Shows durable pull subscription setup, fetch(batch:, timeout:), and message ack/nak.

Backend detection

Source: examples/backend_detection.rb

bundle exec ruby examples/backend_detection.rb

Shows client.resolve_backend(mode: :auto, stream:) selecting :jetstream when the stream exists and falling back to :core otherwise.

Full JetStream round trip

Source: examples/jetstream_roundtrip.rb

bundle exec ruby examples/jetstream_roundtrip.rb

Shows stream creation, durable pull subscription, publish ack, fetch, message metadata, ack, and cleanup.