class NATS::JetStream::PullSubscription

• NATS::JetStream::PullSubscription
• Reference
• Object

Defined in:

jetstream.cr

Constructors

• .new(nats_subscription : NATS::Subscription, consumer : NATS::JetStream::API::V1::Consumer, channel : Channel(NATS::JetStream::Message), nats : NATS::Client)

Instance Method Summary

• #close
• #closed? : Bool
• #consumer : API::V1::Consumer
• #fetch(timeout : Time::Span = 2.seconds)
• #fetch(message_count : Int, timeout : Time::Span = 2.seconds) : Enumerable(Message)
• #nats_subscription : NATS::Subscription

Constructor Detail

Instance Method Detail