1 files changed, 51 insertions, 51 deletions

diff --git a/actionpack/test/controller/live_stream_test.rb b/actionpack/test/controller/live_stream_test.rb
index 5977124594..17dff9542a 100644
--- a/actionpack/test/controller/live_stream_test.rb
+++ b/actionpack/test/controller/live_stream_test.rb
@@ -1,5 +1,5 @@
-require 'abstract_unit'
-require 'concurrent/atomic/count_down_latch'
+require "abstract_unit"
+require "concurrent/atomic/count_down_latch"
 Thread.abort_on_exception = true
 
 module ActionController
@@ -8,7 +8,7 @@ module ActionController
       include ActionController::Live
 
       def basic_sse
-        response.headers['Content-Type'] = 'text/event-stream'
+        response.headers["Content-Type"] = "text/event-stream"
         sse = SSE.new(response.stream)
         sse.write("{\"name\":\"John\"}")
         sse.write({ name: "Ryan" })
@@ -115,7 +115,7 @@ module ActionController
       attr_accessor :latch, :tc, :error_latch
 
       def self.controller_path
-        'test'
+        "test"
       end
 
       def set_cookie
@@ -125,7 +125,7 @@ module ActionController
       end
 
       def render_text
-        render plain: 'zomg'
+        render plain: "zomg"
       end
 
       def default_header
@@ -134,7 +134,7 @@ module ActionController
       end
 
       def basic_stream
-        response.headers['Content-Type'] = 'text/event-stream'
+        response.headers["Content-Type"] = "text/event-stream"
         %w{ hello world }.each do |word|
           response.stream.write word
         end
@@ -142,7 +142,7 @@ module ActionController
       end
 
       def blocking_stream
-        response.headers['Content-Type'] = 'text/event-stream'
+        response.headers["Content-Type"] = "text/event-stream"
         %w{ hello world }.each do |word|
           response.stream.write word
           latch.wait
@@ -151,9 +151,9 @@ module ActionController
       end
 
       def thread_locals
-        tc.assert_equal 'aaron', Thread.current[:setting]
+        tc.assert_equal "aaron", Thread.current[:setting]
 
-        response.headers['Content-Type'] = 'text/event-stream'
+        response.headers["Content-Type"] = "text/event-stream"
         %w{ hello world }.each do |word|
           response.stream.write word
         end
@@ -161,20 +161,20 @@ module ActionController
       end
 
       def with_stale
-        render plain: 'stale' if stale?(etag: "123", template: false)
+        render plain: "stale" if stale?(etag: "123", template: false)
       end
 
       def exception_in_view
-        render 'doesntexist'
+        render "doesntexist"
       end
 
       def exception_in_view_after_commit
         response.stream.write ""
-        render 'doesntexist'
+        render "doesntexist"
       end
 
       def exception_with_callback
-        response.headers['Content-Type'] = 'text/event-stream'
+        response.headers["Content-Type"] = "text/event-stream"
 
         response.stream.on_error do
           response.stream.write %(data: "500 Internal Server Error"\n\n)
@@ -182,11 +182,11 @@ module ActionController
         end
 
         response.stream.write "" # make sure the response is committed
-        raise 'An exception occurred...'
+        raise "An exception occurred..."
       end
 
       def exception_in_controller
-        raise Exception, 'Exception in controller'
+        raise Exception, "Exception in controller"
       end
 
       def bad_request_error
@@ -194,50 +194,50 @@ module ActionController
       end
 
       def exception_in_exception_callback
-        response.headers['Content-Type'] = 'text/event-stream'
+        response.headers["Content-Type"] = "text/event-stream"
         response.stream.on_error do
-          raise 'We need to go deeper.'
+          raise "We need to go deeper."
         end
-        response.stream.write ''
+        response.stream.write ""
         response.stream.write params[:widget][:didnt_check_for_nil]
       end
 
       def overfill_buffer_and_die
         logger = ActionController::Base.logger || Logger.new($stdout)
         response.stream.on_error do
-          logger.warn 'Error while streaming.'
+          logger.warn "Error while streaming."
           error_latch.count_down
         end
 
         # Write until the buffer is full. It doesn't expose that
         # information directly, so we must hard-code its size:
         10.times do
-          response.stream.write '.'
+          response.stream.write "."
         end
         # .. plus one more, because the #each frees up a slot:
-        response.stream.write '.'
+        response.stream.write "."
 
         latch.count_down
 
         # This write will block, and eventually raise
-        response.stream.write 'x'
+        response.stream.write "x"
 
         20.times do
-          response.stream.write '.'
+          response.stream.write "."
         end
       end
 
       def ignore_client_disconnect
         response.stream.ignore_disconnect = true
 
-        response.stream.write '' # commit
+        response.stream.write "" # commit
 
         # These writes will be ignored
         15.times do
-          response.stream.write 'x'
+          response.stream.write "x"
         end
 
-        logger.info 'Work complete'
+        logger.info "Work complete"
         latch.count_down
       end
     end
@@ -245,9 +245,9 @@ module ActionController
     tests TestController
 
     def assert_stream_closed
-      assert response.stream.closed?, 'stream should be closed'
-      assert response.committed?,     'response should be committed'
-      assert response.sent?,          'response should be sent'
+      assert response.stream.closed?, "stream should be closed"
+      assert response.committed?,     "response should be committed"
+      assert response.sent?,          "response should be sent"
     end
 
     def capture_log_output
@@ -271,21 +271,21 @@ module ActionController
 
     def test_set_cookie
       get :set_cookie
-      assert_equal({'hello' => 'world'}, @response.cookies)
+      assert_equal({"hello" => "world"}, @response.cookies)
       assert_equal "hello world", @response.body
     end
 
     def test_write_to_stream
       get :basic_stream
       assert_equal "helloworld", @response.body
-      assert_equal 'text/event-stream', @response.headers['Content-Type']
+      assert_equal "text/event-stream", @response.headers["Content-Type"]
     end
 
     def test_async_stream
       rubinius_skip "https://github.com/rubinius/rubinius/issues/2934"
 
       @controller.latch = Concurrent::CountDownLatch.new
-      parts             = ['hello', 'world']
+      parts             = ["hello", "world"]
 
       get :blocking_stream
 
@@ -299,7 +299,7 @@ module ActionController
         end
       }
 
-      assert t.join(3), 'timeout expired before the thread terminated'
+      assert t.join(3), "timeout expired before the thread terminated"
     end
 
     def test_abort_with_full_buffer
@@ -307,7 +307,7 @@ module ActionController
       @controller.error_latch = Concurrent::CountDownLatch.new
 
       capture_log_output do |output|
-        get :overfill_buffer_and_die, :format => 'plain'
+        get :overfill_buffer_and_die, :format => "plain"
 
         t = Thread.new(response) { |resp|
           resp.await_commit
@@ -321,7 +321,7 @@ module ActionController
 
         t.join
         @controller.error_latch.wait
-        assert_match 'Error while streaming', output.rewind && output.read
+        assert_match "Error while streaming", output.rewind && output.read
       end
     end
 
@@ -344,26 +344,26 @@ module ActionController
         Timeout.timeout(3) do
           @controller.latch.wait
         end
-        assert_match 'Work complete', output.rewind && output.read
+        assert_match "Work complete", output.rewind && output.read
       end
     end
 
     def test_thread_locals_get_copied
       @controller.tc = self
       Thread.current[:originating_thread] = Thread.current.object_id
-      Thread.current[:setting]            = 'aaron'
+      Thread.current[:setting]            = "aaron"
 
       get :thread_locals
     end
 
     def test_live_stream_default_header
       get :default_header
-      assert response.headers['Content-Type']
+      assert response.headers["Content-Type"]
     end
 
     def test_render_text
       get :render_text
-      assert_equal 'zomg', response.body
+      assert_equal "zomg", response.body
       assert_stream_closed
     end
 
@@ -375,7 +375,7 @@ module ActionController
       capture_log_output do |output|
         get :exception_in_view_after_commit
         assert_match %r((window\.location = "/500\.html"</script></html>)$), response.body
-        assert_match 'Missing template test/doesntexist', output.rewind && output.read
+        assert_match "Missing template test/doesntexist", output.rewind && output.read
         assert_stream_closed
       end
       assert response.body
@@ -389,8 +389,8 @@ module ActionController
 
       capture_log_output do |output|
         get :exception_in_view_after_commit, format: :json
-        assert_equal '', response.body
-        assert_match 'Missing template test/doesntexist', output.rewind && output.read
+        assert_equal "", response.body
+        assert_match "Missing template test/doesntexist", output.rewind && output.read
         assert_stream_closed
       end
     end
@@ -399,34 +399,34 @@ module ActionController
       current_threads = Thread.list
 
       capture_log_output do |output|
-        get :exception_with_callback, format: 'text/event-stream'
+        get :exception_with_callback, format: "text/event-stream"
 
         # Wait on the execution of all threads
         (Thread.list - current_threads).each(&:join)
 
         assert_equal %(data: "500 Internal Server Error"\n\n), response.body
-        assert_match 'An exception occurred...', output.rewind && output.read
+        assert_match "An exception occurred...", output.rewind && output.read
         assert_stream_closed
       end
     end
 
     def test_exception_in_controller_before_streaming
       assert_raises(ActionController::LiveStreamTest::Exception) do
-        get :exception_in_controller, format: 'text/event-stream'
+        get :exception_in_controller, format: "text/event-stream"
       end
     end
 
     def test_bad_request_in_controller_before_streaming
       assert_raises(ActionController::BadRequest) do
-        get :bad_request_error, format: 'text/event-stream'
+        get :bad_request_error, format: "text/event-stream"
       end
     end
 
     def test_exceptions_raised_handling_exceptions_and_committed
       capture_log_output do |output|
-        get :exception_in_exception_callback, format: 'text/event-stream'
-        assert_equal '', response.body
-        assert_match 'We need to go deeper', output.rewind && output.read
+        get :exception_in_exception_callback, format: "text/event-stream"
+        assert_equal "", response.body
+        assert_match "We need to go deeper", output.rewind && output.read
         assert_stream_closed
       end
     end
@@ -456,7 +456,7 @@ class LiveStreamRouterTest < ActionDispatch::IntegrationTest
     include ActionController::Live
 
     def index
-      response.headers['Content-Type'] = 'text/event-stream'
+      response.headers["Content-Type"] = "text/event-stream"
       sse = SSE.new(response.stream)
       sse.write("{\"name\":\"John\"}")
       sse.write({ name: "Ryan" })
@@ -474,7 +474,7 @@ class LiveStreamRouterTest < ActionDispatch::IntegrationTest
   end
 
   routes.draw do
-    get '/test' => 'live_stream_router_test/test#index'
+    get "/test" => "live_stream_router_test/test#index"
   end
 
   def app