Contents

# frozen_string_literal: true

require "action_cable"

ActionCable::Channel::Base.prepend(Module.new do
  def subscribe_to_channel
    super unless anycabled? && !@__anycable_subscribing__
  end

  def handle_subscribe
    @__anycable_subscribing__ = true
    subscribe_to_channel
  ensure
    @__anycable_subscribing__ = false
  end

  def start_periodic_timers
    super unless anycabled?
  end

  def stop_periodic_timers
    super unless anycabled?
  end

  def stream_from(broadcasting, _callback = nil, **)
    return super unless anycabled?

    broadcasting = String(broadcasting)

    connection.anycable_socket.subscribe identifier, broadcasting
  end

  def stop_stream_from(broadcasting)
    return super unless anycabled?

    connection.anycable_socket.unsubscribe identifier, broadcasting
  end

  def stop_all_streams
    return super unless anycabled?

    connection.anycable_socket.unsubscribe_from_all identifier
  end

  private

  def anycabled?
    # Use instance variable check here for testing compatibility
    connection.instance_variable_defined?(:@anycable_socket)
  end
end)

Version data entries

13 entries across 13 versions & 2 rubygems

Version	Path
anycable-rails-core-1.5.0.rc.1	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-core-1.4.4	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-core-1.4.3	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-core-1.4.2	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-core-1.4.1	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-core-1.4.0	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.4.0	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.4.0.rc.4	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.4.0.rc.3	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.4.0.rc.2	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.4.0.rc.1	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.3.7	lib/anycable/rails/action_cable_ext/channel.rb
anycable-rails-1.3.6	lib/anycable/rails/action_cable_ext/channel.rb