class NATS::Subscription
Attributes
callback[RW]
future[RW]
is_slow_consumer[RW]
max[RW]
pending[RW]
pending_bytes_limit[RW]
pending_msgs_limit[RW]
pending_queue[RW]
pending_size[RW]
queue[RW]
received[RW]
response[RW]
subject[RW]
wait_for_msgs_t[RW]
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/nats/io/client.rb, line 1726 def initialize super # required to initialize monitor @subject = '' @queue = nil @future = nil @callback = nil @response = nil @received = 0 @max = nil @pending = nil # State from async subscriber messages delivery @pending_queue = nil @pending_size = 0 @pending_msgs_limit = nil @pending_bytes_limit = nil @wait_for_msgs_t = nil @is_slow_consumer = false end