Module: Pgbus::Streams::TurboStreamOverride

Includes:
Pgbus::StreamsHelper
Defined in:
lib/pgbus/streams/turbo_stream_override.rb

Overview

Runtime patch that redirects turbo_stream_from (the view helper) through pgbus_stream_from when pgbus streams are enabled. This is the subscribe-side counterpart to TurboBroadcastable (which patches the publish-side broadcast_stream_to).

Without this patch, third-party gems like hotwire-livereload call turbo_stream_from "hotwire-livereload" in their views, which renders a <turbo-cable-stream-source> element connected to ActionCable. Meanwhile, the TurboBroadcastable patch routes the broadcast through PGMQ/SSE. Publisher and subscriber end up on different transports — the message never arrives.

After this patch, turbo_stream_from renders a <pgbus-stream-source> element instead, so both sides use PGMQ/SSE. When streams_enabled is false, the original turbo-rails behavior is preserved via super.

The include Pgbus::StreamsHelper is required because some callers invoke turbo_stream_from from a Rack middleware context (e.g. hotwire-livereload's Middleware uses ActionController::Base.helpers) where Turbo::StreamsHelper is available but Pgbus::StreamsHelper is not — the engine's isolate_namespace scopes helpers to its own views. Including it here ensures pgbus_stream_from is always reachable on the receiver.

Instance Method Summary collapse

Methods included from Pgbus::StreamsHelper

#pgbus_stream_from

Instance Method Details

#turbo_stream_from(*streamables, **attributes) ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/pgbus/streams/turbo_stream_override.rb', line 31

def turbo_stream_from(*streamables, **attributes)
  if Pgbus.configuration.streams_enabled
    pgbus_stream_from(*streamables, **attributes)
  else
    super
  end
end