Improve concurrent streaming error handling and configuration#2017

Closed

justin808 wants to merge 46 commits intomasterfrom

justin808/stream-error-handling

Commits on Nov 15, 2025

add concurrent_stream_drain flag (default false)
ihabadham
committed
add and bundle async runtime dependency
ihabadham
committed
concurrent fiber draining via Async with single writer; add tracing logs; behind config flag
ihabadham
committed
make sequential draining robust to already finished fibers
ihabadham
committed
add default backpressure via Async::Semaphore and handle client disconnects
ihabadham
committed
add controller streaming specs for sequential vs concurrent, ordering, edge cases, and producer error
ihabadham
committed
add a test for backpressure
ihabadham
committed
refactor to correct rubocop offenses
ihabadham
committed
fix NoMethodError caused by Array.bytesize
ihabadham
committed
add concurrent_stream_queue_capacity (default 64) and use it in streaming backpressure
ihabadham
committed
add a comment explaining why semaphore.acquire is preferable to semaphore.async.
ihabadham
committed
refactor(stream): use Async::Queue#close as a final single sentinel; start writer before producers; remove per-producer done markers
ihabadham
committed
refactor: propagate streaming errors instead of rescuing
ihabadham
committed
ci: correct rubocop offenses
ihabadham
committed
add a simpler test for the concurrent stream_view_containing_react_components

AbanoubGhadban
authored and
ihabadham
committed
refactor streaming tests to use pure mock approach
ihabadham
committed
DRY the tests
ihabadham
committed
remove the concurrent_stream_drain config flag and always stream components concurrently
ihabadham
committed
remove debug logging
ihabadham
committed
correct rubocop offenses
ihabadham
committed
use async queue instead of ruby array at helper spec

AbanoubGhadban
authored and
ihabadham
committed
Revert "use async queue instead of ruby array at helper spec"

AbanoubGhadban
authored and
ihabadham
committed
Enhance helper spec to support Async::Queue for chunk processing

AbanoubGhadban
authored and
ihabadham
committed
Revert "Enhance helper spec to support Async::Queue for chunk processing"

AbanoubGhadban
authored and
ihabadham
committed
Refactor helper spec to utilize Async::Queue for improved chunk processing

AbanoubGhadban
authored and
ihabadham
committed
Refactor configuration and streaming logic to use concurrent_component_streaming_buffer_size for improved memory management and validation

AbanoubGhadban
authored and
ihabadham
committed
Refactor streaming logic to remove unnecessary error handling for improved clarity and performance

AbanoubGhadban
authored and
ihabadham
committed
pass buffer_size to LimitedQueue as a positional argument because it doesn't expect a :size keyword argument
ihabadham
committed
ci: correct rubocop offenses
ihabadham
committed
ci: avoid getting a rubocop error
ihabadham
committed
update CHANGELOG.md
ihabadham
committed
Update react_on_rails to 16.0.1.rc.4 to fix yanked version issue
ihabadham
committed
remove accidently pushed Gemfile.local.backup
ihabadham
committed
git ignore .claude/
ihabadham
committed
Fix ReactOnRails::PackerUtils.using_packer? compatibility with react_on_rails 16.0
ihabadham
committed
Remove redundant .claude/ entry from react_on_rails_pro/.gitignore
ihabadham
committed
Add missing validation call for concurrent_component_streaming_buffer_size
ihabadham
committed
Validate buffer size as Integer instead of Numeric
ihabadham
committed
Add test for client disconnect cleanup behavior

github-actions[bot]
and
ihabadham
committed
Revert "Add test for client disconnect cleanup behavior"
ihabadham
committed
Improve concurrent streaming error handling and configuration

justin808
authored and
ihabadham
committed
Fix test mocks to support stream.closed? checks

ihabadham
and
claude
committed
Fix client disconnect test to properly simulate stream.closed?

ihabadham
and
claude
committed
Refactor: Move disconnect test to stream_spec.rb for better organization

ihabadham
and
claude
committed
Remove unused index variable from producer-consumer queue

ihabadham
and
claude
committed
Remove redundant buffer size validation method

ihabadham
and
claude
committed