app/volt/tasks/live_query/live_query.rb in volt-0.9.1.pre1 vs app/volt/tasks/live_query/live_query.rb in volt-0.9.1.pre2
- old
+ new
@@ -83,13 +83,19 @@
def add_channel(channel)
@channels << channel
end
def remove_channel(channel)
- @channels.delete(channel)
+ deleted = @channels.delete(channel)
# remove this query, no one is listening anymore
- @pool.remove(@collection, @query) if @channels.empty?
+ if @channels.empty?
+ begin
+ @pool.remove(@collection, @query)
+ rescue Volt::GenericPoolDeleteException => e
+ # ignore
+ end
+ end
end
def notify!(skip_channel = nil, only_channel = nil)
if only_channel
channels = [only_channel]