Contents

# frozen_string_literal: true

require "action_cable"

ActionCable::Server::Base.prepend(Module.new do
  def broadcast(channel, payload, **options)
    return super if options.empty?

    AnyCable::Rails.with_broadcast_options(**options) do
      super(channel, payload)
    end
  end

  def broadcaster_for(broadcasting, **options)
    broadcasting = AnyCable::Rails.stream_name_from(broadcasting)
    super(broadcasting, **options)
  end
end)

ActionCable::Channel::Base.singleton_class.prepend(Module.new do
  def broadcast_to(target, payload, **options)
    return super if options.empty?

    AnyCable::Rails.with_broadcast_options(**options) do
      super(target, payload)
    end
  end
end)

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
anycable-rails-core-1.5.1	lib/anycable/rails/action_cable_ext/broadcast_options.rb
anycable-rails-core-1.5.0	lib/anycable/rails/action_cable_ext/broadcast_options.rb
anycable-rails-core-1.5.0.rc.1	lib/anycable/rails/action_cable_ext/broadcast_options.rb