class NATS::Subscription

• NATS::Subscription
• Reference
• Object

Defined in:

nats.cr

Constructors

• .new(subject : String, sid : Int64, queue_group : Nil | String, nats : NATS::Client, max_in_flight : Int = 10, &block : Message, Subscription -> )

Instance Method Summary

• #close
• #drain : Nil
• #messages_remaining : Int32 | Nil
• #queue_group : String | Nil
• #send(message, &on_error : Exception -> ) : Nil
• #sid : Int64
• #start : self
• #subject : String
• #unsubscribe_after(messages messages_remaining : Int32)

Constructor Detail

Instance Method Detail