class

NATS::Subscription

Inherits Reference / Object

Constructors

new(subject : String, sid : Int64, queue_group : Nil | String, nats : NATS::Client, max_in_flight : Int32, *, concurrency : Int32, &block : Message, Subscription -> )
Source

Instance methods

close
Source
closed?
Source
concurrency
Source
drain
Source
max_in_flight
Source
messages_remaining
Source
queue_group
Source
send(message, &on_error : Exception -> ) : Nil
Source
start
Source
subject
Source
unsubscribe_after(messages messages_remaining : Int32)
Source

Nested types