method

worker_pool_stream_handler

v6.1.7.7 - Show latest stable - 0 notes - Class: Streams

1.0.0
1.1.6
1.2.6
2.0.3
2.1.0
2.2.1
2.3.8
3.0.0
3.0.9
3.1.0
3.2.1
3.2.8
3.2.13
4.0.2
4.1.8
4.2.1
4.2.7
4.2.9
5.0.0.1 (0)
5.1.7 (0)
5.2.3 (0)
6.0.0 (0)
6.1.3.1 (0)
6.1.7.7 (0)
7.0.0 (0)
7.1.3.2 (0)
7.1.3.4 (0)
What's this?

worker_pool_stream_handler(broadcasting, user_handler, coder: nil) private

Always wrap the outermost handler to invoke the user handler on the worker pool rather than blocking the event loop.

# File actioncable/lib/action_cable/channel/streams.rb, line 148
        def worker_pool_stream_handler(broadcasting, user_handler, coder: nil)
          handler = stream_handler(broadcasting, user_handler, coder: coder)

          -> message do
            connection.worker_pool.async_invoke handler, :call, message, connection: connection
          end
        end

worker_pool_stream_handler

Related methods