Merge pull request #29 from marinso/fix_lists

Fix lists

Author: thisredone

Diff for: lib/deepstream/list.rb

@@ -5,6 +5,8 @@ module Deepstream
   class List < Record
     LIST_CALLBACKS = %i{added removed}
 
+    attr_reader :version
+
     def initialize(*args)
       super
       @data = []
@@ -15,7 +17,7 @@ def add(record_name)
       unless @data.include?(record_name)
         @data << record_name
         set
-        notify_listeners(:removed, record_name)
+        notify_listeners(:added, record_name)
       end
     rescue => e
       @client.on_exception(e)
@@ -98,4 +100,4 @@ def notify_listeners(cb_name, uid)
       end
     end
   end
-end
+end

Diff for: lib/deepstream/record_handler.rb

@@ -32,6 +32,7 @@ def get(name, list: nil)
       if list
         name.prepend("#{list}/")
         @records[list] ||= List.new(@client, list)
+        sleep 0.1 while @records[list].version.nil?
         @records[list].add(name)
       end
       @records[name] ||= Record.new(@client, name)