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