Fix rubocop warnings

Author: route

lib/ferrum/browser/client.rb

@@ -1,6 +1,5 @@
 # frozen_string_literal: true
 
-require "concurrent-ruby"
 require "ferrum/browser/subscriber"
 require "ferrum/browser/web_socket"
 
@@ -14,15 +13,18 @@ def initialize(browser, ws_url, id_starts_with: 0)
         @command_id = id_starts_with
         @pendings = Concurrent::Hash.new
         @ws = WebSocket.new(ws_url, @browser.ws_max_receive_size, @browser.logger)
-        @subscriber, @interruptor = Subscriber.build(2)
+        @subscriber, @interrupter = Subscriber.build(2)
 
         @thread = Thread.new do
           Thread.current.abort_on_exception = true
           Thread.current.report_on_exception = true if Thread.current.respond_to?(:report_on_exception=)
 
-          while message = @ws.messages.pop
+          loop do
+            message = @ws.messages.pop
+            break unless message
+
             if INTERRUPTIONS.include?(message["method"])
-              @interruptor.async.call(message)
+              @interrupter.async.call(message)
             elsif message.key?("method")
               @subscriber.async.call(message)
             else
@@ -51,14 +53,14 @@ def command(method, params = {})
       def on(event, &block)
         case event
         when *INTERRUPTIONS
-          @interruptor.on(event, &block)
+          @interrupter.on(event, &block)
         else
           @subscriber.on(event, &block)
         end
       end
 
       def subscribed?(event)
-        [@interruptor, @subscriber].any? { |s| s.subscribed?(event) }
+        [@interrupter, @subscriber].any? { |s| s.subscribed?(event) }
       end
 
       def close

lib/ferrum/browser/subscriber.rb

@@ -1,7 +1,5 @@
 # frozen_string_literal: true
 
-require "concurrent-ruby"
-
 module Ferrum
   class Browser
     class Subscriber

lib/ferrum/browser/web_socket.rb

@@ -32,7 +32,10 @@ def initialize(url, max_receive_size, logger)
           Thread.current.report_on_exception = true if Thread.current.respond_to?(:report_on_exception=)
 
           begin
-            while data = @sock.readpartial(512)
+            loop do
+              data = @sock.readpartial(512)
+              break unless data
+
               @driver.parse(data)
             end
           rescue EOFError, Errno::ECONNRESET, Errno::EPIPE