app/jobs/turbo_boost/streams/broadcast_invoke_job.rb
# frozen_string_literal: true
class TurboBoost::Streams::BroadcastInvokeJob < ActiveJob::Base
include TurboBoost::Streams::TagHelper
def perform(*streamables, method, **kwargs)
Turbo::StreamsChannel.broadcast_stream_to(*streamables, content: turbo_stream_invoke_tag(method, **kwargs))
end
end