Revert "Enhance helper spec to support Async::Queue for chunk processing"

This reverts commit 41f5eb9.

Author: AbanoubGhadban

spec/dummy/spec/helpers/react_on_rails_pro_helper_spec.rb

@@ -1,7 +1,5 @@
 # frozen_string_literal: true
 
-require "async"
-require "async/queue"
 require "rails_helper"
 require "support/script_tag_utils"
 
@@ -329,7 +327,6 @@ def response; end
       HTML
     end
 
-    # Mock chunks can be Async::Queue or Array
     def mock_request_and_response(mock_chunks = chunks, count: 1)
       # Reset connection instance variables to ensure clean state for tests
       ReactOnRailsPro::Request.instance_variable_set(:@connection, nil)
@@ -342,16 +339,9 @@ def mock_request_and_response(mock_chunks = chunks, count: 1)
       chunks_read.clear
       mock_streaming_response(%r{http://localhost:3800/bundles/[a-f0-9]{32}-test/render/[a-f0-9]{32}}, 200,
                               count: count) do |yielder|
-        if mock_chunks.is_a?(Async::Queue)
-          while (chunk = mock_chunks.dequeue)
-            chunks_read << chunk
-            yielder.call("#{chunk.to_json}\n")
-          end
-        else
-          mock_chunks.each do |chunk|
-            chunks_read << chunk
-            yielder.call("#{chunk.to_json}\n")
-          end
+        mock_chunks.each do |chunk|
+          chunks_read << chunk
+          yielder.call("#{chunk.to_json}\n")
         end
       end
     end
@@ -421,7 +411,6 @@ def mock_request_and_response(mock_chunks = chunks, count: 1)
     describe "stream_view_containing_react_components" do # rubocop:disable RSpec/MultipleMemoizedHelpers
       let(:mocked_stream) { instance_double(ActionController::Live::Buffer) }
       let(:written_chunks) { [] }
-      let(:chunks_queue) { Async::Queue.new }
 
       before do
         written_chunks.clear
@@ -439,55 +428,18 @@ def mock_request_and_response(mock_chunks = chunks, count: 1)
 
         allow(mocked_stream).to receive(:write) do |chunk|
           written_chunks << chunk
+          # Ensures that any chunk received is written immediately to the stream
+          expect(written_chunks.count).to eq(chunks_read.count) # rubocop:disable RSpec/ExpectInHook
         end
         allow(mocked_stream).to receive(:close)
         mocked_response = instance_double(ActionDispatch::Response)
         allow(mocked_response).to receive(:stream).and_return(mocked_stream)
         allow(self).to receive(:response).and_return(mocked_response)
-        mock_request_and_response(chunks_queue)
-      end
-
-      def run_stream
-        queue = chunks_queue
-        Sync do |parent|
-          parent.async do
-            stream_view_containing_react_components(template: template_path)
-          end
-
-          writer = Object.new
-          chunks_to_write = chunks.dup
-          writer.define_singleton_method(:write_next_chunk) do
-            chunk = chunks_to_write.shift
-            if chunk.nil?
-              queue.close
-              parent.sleep 0.05
-              return nil
-            end
-
-            queue.enqueue(chunk)
-            parent.sleep 0.05
-            chunk
-          end
-          writer.define_singleton_method(:write_rest_of_chunks) do
-            while (chunk = chunks_to_write.shift)
-              queue.enqueue(chunk)
-            end
-            parent.sleep 0.1
-          end
-          yield(writer)
-        end
+        mock_request_and_response
       end
 
       it "writes the chunk to stream as soon as it is received" do
-        run_stream do |writer|
-          expect(self).to have_received(:render_to_string)
-
-          while writer.write_next_chunk
-            # Ensures that any chunk received is written immediately to the stream
-            expect(written_chunks.count).to eq(chunks_read.count)
-          end
-        end
-
+        stream_view_containing_react_components(template: template_path)
         expect(self).to have_received(:render_to_string).once.with(template: template_path)
         expect(chunks_read.count).to eq(chunks.count)
         expect(written_chunks.count).to eq(chunks.count)