kotovalexarian-likes-github/rails--rails
1
0
Fork 0
mirror of https://github.com/rails/rails.git synced 2022-11-09 12:12:34 -05:00
Code Releases Activity

Wait for the socket to be closed asynchronously

Browse source
This commit is contained in:
Matthew Draper 2016-10-06 13:12:35 +10:30
parent acd7ba795e
commit 1fe967d0c9
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
actioncable/test/connection/client_socket_test.rb
View file

@ -51,10 +51,12 @@ class ActionCable::Connection::ClientSocketTest < ActionCable::TestCase
connection = open_connection
client = connection.websocket.send(:websocket)
event = Concurrent::Event.new
client.instance_variable_get("@stream")
.instance_variable_get("@rack_hijack_io")
.expects(:close)
.define_singleton_method(:close) { event.set }
connection.close
event.wait
end
end
@ -63,7 +65,13 @@ class ActionCable::Connection::ClientSocketTest < ActionCable::TestCase
env = Rack::MockRequest.env_for "/test",
"HTTP_CONNECTION" => "upgrade", "HTTP_UPGRADE" => "websocket",
"HTTP_HOST" => "localhost", "HTTP_ORIGIN" => "http://rubyonrails.com"
env["rack.hijack"] = -> { env["rack.hijack_io"] = StringIO.new }
io = \
begin
Socket.pair(Socket::AF_UNIX, Socket::SOCK_STREAM, 0).first
rescue
StringIO.new
end
env["rack.hijack"] = -> { env["rack.hijack_io"] = io }
Connection.new(@server, env).tap do |connection|
connection.process