Close socket, terminate reactorm, closes #222.

lib/slack/real_time/concurrency/async.rb

@@ -13,8 +13,9 @@ class Socket < Slack::RealTime::Socket
           attr_reader :client
 
           def start_async(client)
-            Thread.new do
-              ::Async::Reactor.run do
+            @thread = Thread.new do
+              @reactor = ::Async::Reactor.new
+              @reactor.run do
                 client.run_loop
               end
             end
@@ -26,7 +27,11 @@ def connect!
           end
 
           def close
-            @driver.close
+            logger.warn "close: #{self}"
+            close_driver
+            close_socket
+            stop_reactor
+            terminate_thread
             super
           end
 
@@ -38,6 +43,34 @@ def run_loop
 
           protected
 
+          def close_driver
+            logger.warn "close_driver: #{@driver}"
+            return unless @driver
+            @driver.close
+            @driver = nil
+          end
+
+          def close_socket
+            logger.warn "close_socket: #{@socket}"
+            return unless @socket
+            @socket.close
+            @socket = nil
+          end
+
+          def stop_reactor
+            logger.warn "stop_reactor: #{@reactor}"
+            return unless @reactor
+            @reactor.stop
+            @reactor = nil
+          end
+
+          def terminate_thread
+            logger.warn "terminate_thread: #{@thread}"
+            return unless @thread
+            @thread.kill
+            @thread = nil
+          end
+
           def build_ssl_context
             OpenSSL::SSL::SSLContext.new(:TLSv1_2_client).tap do |ctx|
               ctx.set_params(verify_mode: OpenSSL::SSL::VERIFY_PEER)
@@ -50,8 +83,13 @@ def build_endpoint
             endpoint
           end
 
+          def connect_socket
+            build_endpoint.connect
+          end
+
           def connect
-            @driver = Client.new(build_endpoint.connect, url)
+            @socket = connect_socket
+            @driver = Client.new(@socket, url)
           end
         end
       end