Merge pull request #28 from ciesielskilucas/reversion_error

Reversion error

Author: thisredone

Diff for: lib/deepstream/client.rb

@@ -34,8 +34,9 @@ def initialize(url, options = {})
       @challenge_denied, @@deliberate_close = false
       @state = CONNECTION_STATE::CLOSED
       @verbose = @options[:verbose]
+      @reinitialize_master = @options[:reinitialize_master]
       @log = Async.logger
-      @never_connected_before = true
+      @connected_before = false
       connect
     end
 
@@ -156,7 +157,7 @@ def on_challenge
     def on_connection_ack
       @state = CONNECTION_STATE::AUTHENTICATING
       @message_buffer.delete_if { |msg| msg.action == ACTION::PATCH }
-      @record_handler.reinitialize unless @never_connected_before
+      @record_handler.reinitialize if @connected_before
       login
     end
 
@@ -166,7 +167,7 @@ def on_ping
     end
 
     def on_login
-      @never_connected_before = false
+      @connected_before = true
       @state = CONNECTION_STATE::OPEN
       every(@options[:heartbeat_interval]) { check_heartbeat } if @options[:heartbeat_interval]
       resubscribe

Diff for: lib/deepstream/helpers.rb

@@ -38,7 +38,8 @@ def self.default_options
         heartbeat_interval: nil,
         in_thread: true,
         verbose: false,
-        debug: false
+        debug: false,
+        reinitialize_master: false
       }
     end
 

Diff for: lib/deepstream/record.rb

@@ -40,8 +40,8 @@ def start_reinitializing
     end
 
     def end_reinitializing
-      reset_version
-      set(@data_cache)
+      reset_version if @client.options[:reinitialize_master]
+      set(@data_cache) if @client.options[:reinitialize_master]
       @is_reinitializing = false
     end