socketry
diff --git a/‎async-rspec.gemspec
Lines changed: 1 addition & 0 deletions b/‎async-rspec.gemspec
Lines changed: 1 addition & 0 deletions
diff --git a/‎lib/async/rspec/reactor.rb
Lines changed: 1 addition & 4 deletions b/‎lib/async/rspec/reactor.rb
Lines changed: 1 addition & 4 deletions
diff --git a/‎spec/async/rspec/reactor_spec.rb
Lines changed: 11 additions & 8 deletions b/‎spec/async/rspec/reactor_spec.rb
Lines changed: 11 additions & 8 deletions
@@ -18,6 +18,7 @@ Gem::Specification.new do |spec|
 	spec.add_dependency "rspec-memory", "~> 1.0"
 
 	spec.add_development_dependency "async", "~> 1.24"
+	spec.add_development_dependency "async-io"
 	spec.add_development_dependency "bundler"
 	spec.add_development_dependency "covered"
 	spec.add_development_dependency "rake", "~> 10.0"
 
@@ -21,9 +21,7 @@
 require_relative 'leaks'
 
 require 'kernel/async'
-
 require 'async/reactor'
-require 'async/debug/selector'
 
 module Async
 	module RSpec
@@ -79,8 +77,7 @@ def run_in_reactor(reactor, duration = nil)
 
 		::RSpec.shared_context Reactor do
 			include Reactor
-			
-			let(:reactor) {Async::Reactor.new(selector: Async::Debug::Selector.new)}
+			let(:reactor) {Async::Reactor.new}
 
 			include_context Async::RSpec::Leaks
 
 
@@ -19,6 +19,7 @@
 # THE SOFTWARE.
 
 require 'async/rspec/reactor'
+require 'async/io/generic'
 
 RSpec.describe Async::RSpec::Reactor do
 	context "with shared context", timeout: 1 do
@@ -54,17 +55,19 @@
 		include_context Async::RSpec::Reactor
 
 		it "should fail if registering the same io twice" do
-			input, output = IO.pipe
+			input, output = IO.pipe.map{|io| Async::IO::Generic.new(io)}
 
-			monitor = reactor.register(input, :r)
+			reactor.async do
+				input.read
+			end
 
 			expect do
-				reactor.register(input, :r)
-			end.to raise_error(RuntimeError, /already registered/)
-			
-			monitor.close
-			input.close
-			output.close
+				input.read
+			end.to raise_error(/already registered|already waiting/)
+		
+		ensure
+			input&.close
+			output&.close
 		end
 	end