lib/slack/real_time/concurrency/celluloid.rb in slack-ruby-client-0.7.3 vs lib/slack/real_time/concurrency/celluloid.rb in slack-ruby-client-0.7.4

@@ -45,9 +45,13 @@
             driver.close
           end
 
           def read
             buffer = socket.readpartial(BLOCK_SIZE)
+            async.handle_read(buffer)
+          end
+
+          def handle_read(buffer)
             logger.debug("#{self.class}##{__method__}") { buffer }
             driver.parse buffer
           end
 
           def write(data)