Sha256: dd3eaaa9d5025138c1aacec0b6ce4196d733ced6ff35bb00172e6718c7cfb798
Contents?: true
Size: 1.78 KB
Versions: 16
Compression:
Stored size: 1.78 KB
Contents
require_relative 'live_query/data_store'
require_relative 'live_query/live_query_pool'
class QueryTasks
@@live_query_pool = LiveQueryPool.new(DataStore.new)
@@channel_live_queries = {}
def self.live_query_pool
@@live_query_pool
end
# The dispatcher passes its self in
def initialize(channel, dispatcher=nil)
@channel = channel
@dispatcher = dispatcher
end
def add_listener(collection, query)
live_query = @@live_query_pool.lookup(collection, query)
track_channel_in_live_query(live_query)
# puts "Load data on #{collection.inspect} - #{query.inspect}"
live_query.add_channel(@channel)
errors = {}
begin
# Get the initial data
initial_data = live_query.initial_data
rescue => exception
# Capture and pass up any exceptions
error = {:error => exception.message}
end
return initial_data, error
end
def initial_data
data = live_query.initial_data
data['_id'] = data['_id'].to_s
return data
end
# Remove a listening channel, the LiveQuery will automatically remove
# itsself from the pool when there are no channels.
def remove_listener(collection, query)
live_query = @@live_query_pool.lookup(collection, query)
live_query.remove_channel(@channel)
end
# Removes a channel from all associated live queries
def close!
live_queries = @@channel_live_queries[@channel]
if live_queries
live_queries.each do |live_query|
live_query.remove_channel(@channel)
end
end
@@channel_live_queries.delete(@channel)
end
private
# Tracks that this channel will be notified from the live query.
def track_channel_in_live_query(live_query)
@@channel_live_queries[@channel] ||= []
@@channel_live_queries[@channel] << live_query
end
end
Version data entries
16 entries across 16 versions & 1 rubygems