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