client.rb in async-redis-0.8.1

- old
+ new

@@ -1,33 +1,32 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2018-2023, by Samuel Williams.
+# Copyright, 2018-2024, by Samuel Williams.
 # Copyright, 2018, by Huba Nagy.
 # Copyright, 2019, by Mikael Henriksson.
 # Copyright, 2019, by David Ortiz.
 # Copyright, 2020, by Salim Semaoune.
 
 require_relative 'context/pipeline'
 require_relative 'context/transaction'
 require_relative 'context/subscribe'
-
 require_relative 'protocol/resp2'
 
-require 'async/io'
-require 'async/io/stream'
+require 'io/endpoint/host_endpoint'
 require 'async/pool/controller'
-
 require 'protocol/redis/methods'
 
+require 'io/stream'
+
 module Async
 	module Redis
 		# Legacy.
 		ServerError = ::Protocol::Redis::ServerError
 		
 		def self.local_endpoint(port: 6379)
-			Async::IO::Endpoint.tcp('localhost', port)
+			::IO::Endpoint.tcp('localhost', port)
 		end
 		
 		class Client
 			include ::Protocol::Redis::Methods
 			
@@ -119,10 +118,10 @@
 					peer = @endpoint.connect
 					
 					# We will manage flushing ourselves:
 					peer.sync = true
 					
-					stream = IO::Stream.new(peer)
+					stream = ::IO::Stream(peer)
 					
 					@protocol.client(stream)
 				end
 			end
 		end