spec/async/io/shared_endpoint/server_spec.rb in async-io-1.18.2 vs spec/async/io/shared_endpoint/server_spec.rb in async-io-1.18.3
- old
+ new
@@ -34,11 +34,11 @@
let(:endpoint) {Async::IO::Endpoint.tcp("127.0.0.1", 6781, reuse_port: true)}
let(:server_endpoint) {Async::IO::SSLEndpoint.new(endpoint, ssl_context: server_context)}
let(:client_endpoint) {Async::IO::SSLEndpoint.new(endpoint, ssl_context: client_context)}
let!(:bound_endpoint) do
- Async::Reactor.run do
+ Async do
Async::IO::SharedEndpoint.bound(server_endpoint)
end.wait
end
it "can use bound endpoint in container" do
@@ -47,10 +47,10 @@
peer.write "Hello World"
peer.close
end
end
- Async::Reactor.run do
+ Async do
client_endpoint.connect do |peer|
expect(peer.read(11)).to eq "Hello World"
end
end