Remove dependency on async-io.

async-websocket.gemspec

@@ -25,7 +25,6 @@ Gem::Specification.new do |spec|
 	spec.required_ruby_version = ">= 3.0"
 
 	spec.add_dependency "async-http", "~> 0.54"
-	spec.add_dependency "async-io", "~> 1.23"
-	spec.add_dependency "protocol-rack", "~> 0.1"
+	spec.add_dependency "protocol-rack", "~> 0.5"
 	spec.add_dependency "protocol-websocket", "~> 0.11"
 end

examples/chat/client.rb

@@ -5,7 +5,6 @@
 # Copyright, 2018-2022, by Samuel Williams.
 
 require 'async'
-require 'async/io/stream'
 require 'async/http/endpoint'
 require_relative '../../lib/async/websocket/client'
 require 'protocol/websocket/json_message'
@@ -15,13 +14,9 @@
 ENDPOINT = Async::HTTP::Endpoint.parse(URL)
 
 Async do |task|
-	stdin = Async::IO::Stream.new(
-		Async::IO::Generic.new($stdin)
-	)
-
 	Async::WebSocket::Client.connect(ENDPOINT) do |connection|
 		input_task = task.async do
-			while line = stdin.read_until("\n")
+			while line = $stdin.gets
 				message = Protocol::WebSocket::JSONMessage.generate({text: line})
 				message.send(connection)
 				connection.flush

examples/chat/multi-client.rb

@@ -7,7 +7,6 @@
 require 'async'
 require 'async/semaphore'
 require 'async/clock'
-require 'async/io/stream'
 require 'async/http/endpoint'
 require 'protocol/websocket/json_message'
 require_relative '../../lib/async/websocket/client'
@@ -28,7 +27,7 @@ class Command < Samovar::Command
 
 	def local_address
 		if bind = @options[:bind]
-			Async::IO::Address.tcp(bind, 0)
+			Addrinfo.tcp(bind, 0)
 		end
 	end
 

examples/mud/client.rb

@@ -6,25 +6,20 @@
 # Copyright, 2020, by Juan Antonio Martín Lucas.
 
 require 'async'
-require 'async/io/stream'
 require 'async/http/endpoint'
 require 'async/websocket/client'
 
 USER = ARGV.pop || "anonymous"
 URL = ARGV.pop || "http://127.0.0.1:7070"
 
 Async do |task|
-	stdin = Async::IO::Stream.new(
-		Async::IO::Generic.new($stdin)
-	)
-
 	endpoint = Async::HTTP::Endpoint.parse(URL)
 
 	Async::WebSocket::Client.connect(endpoint) do |connection|
 		task.async do
 			$stdout.write "> "
 
-			while line = stdin.read_until("\n")
+			while line = $stdin.gets
 				connection.write({input: line})
 				connection.flush
 

examples/polygon.io/client.rb

@@ -5,7 +5,6 @@
 # Copyright, 2020-2022, by Samuel Williams.
 
 require 'async'
-require 'async/io/stream'
 require 'async/http/endpoint'
 
 require 'hexdump'

fixtures/rack_application/client.rb

@@ -5,24 +5,19 @@
 # Copyright, 2018-2023, by Samuel Williams.
 
 require 'async'
-require 'async/io/stream'
 require 'async/http/endpoint'
 require 'async/websocket/client'
 
 USER = ARGV.pop || "anonymous"
 URL = ARGV.pop || "http://localhost:7070"
 
 Async do |task|
-	stdin = Async::IO::Stream.new(
-		Async::IO::Generic.new($stdin)
-	)
-
 	endpoint = Async::HTTP::Endpoint.parse(URL)
 	headers = {'token' => 'wubalubadubdub'}
 
 	Async::WebSocket::Client.open(endpoint, headers: headers) do |connection|
 		input_task = task.async do
-			while line = stdin.read_until("\n")
+			while line = $stdin.gets
 				connection.write({user: USER, text: line})
 				connection.flush
 			end

guides/getting-started/readme.md

@@ -20,23 +20,18 @@ $ bundle add async-websocket
 #!/usr/bin/env ruby
 
 require 'async'
-require 'async/io/stream'
 require 'async/http/endpoint'
 require 'async/websocket/client'
 
 USER = ARGV.pop || "anonymous"
 URL = ARGV.pop || "http://localhost:7070"
 
 Async do |task|
-	stdin = Async::IO::Stream.new(
-		Async::IO::Generic.new($stdin)
-	)
-
 	endpoint = Async::HTTP::Endpoint.parse(URL)
 
 	Async::WebSocket::Client.connect(endpoint) do |connection|
 		input_task = task.async do
-			while line = stdin.read_until("\n")
+			while line = $stdin.gets
 				connection.write({user: USER, text: line})
 				connection.flush
 			end