class DDP::Server::Protocol::Data::Subscription
Actor that asynchronously monitors a collection
Attributes
id[R]
listener[R]
name[R]
query[R]
stopped[R]
stopped?[R]
Public Class Methods
new(listener, id, name, query)
click to toggle source
# File lib/ddp/server/protocol/data.rb, line 90 def initialize(listener, id, name, query) @stopped = false @name = name @listener = listener @id = id @query = query end
Public Instance Methods
start()
click to toggle source
# File lib/ddp/server/protocol/data.rb, line 98 def start query.call do |old_value, new_value| listener.subscription_update(id, old_value, new_value) break if stopped? end end
stop()
click to toggle source
# File lib/ddp/server/protocol/data.rb, line 105 def stop @stopped = true end