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