модуль ActionCable::Channel::TestCase::Behavior

Включенные модули:: ActiveSupport::Testing::ConstantLookup, ActionCable::TestHelper

Константы

CHANNEL_IDENTIFIER

Общедоступные методы экземпляров

assert_broadcast_on(stream_or_object, *args) Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 258
def assert_broadcast_on(stream_or_object, *args)
  super(broadcasting_for(stream_or_object), *args)
end

Вызывает метод суперкласса ActionCable::TestHelper#assert_broadcast_on

assert_broadcasts(stream_or_object, *args) Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 254
def assert_broadcasts(stream_or_object, *args)
  super(broadcasting_for(stream_or_object), *args)
end

Расширяет проверки TestHelper, чтобы обрабатывать нестроковые трансляции

Вызывает метод суперкласса ActionCable::TestHelper#assert_broadcasts

assert_has_stream(stream) Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 280
def assert_has_stream(stream)
  assert subscription.streams.include?(stream), "Stream #{stream} has not been started"
end

Проверяет, что указанный поток запущен.

def test_assert_started_stream
  subscribe
  assert_has_stream 'messages'
end

assert_has_stream_for(object) Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 291
def assert_has_stream_for(object)
  assert_has_stream(broadcasting_for(object))
end

Проверяет, что указанный поток для модели запущен.

def test_assert_started_stream_for
  subscribe id: 42
  assert_has_stream_for User.find(42)
end

assert_no_streams() Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 269
def assert_no_streams
  assert subscription.streams.empty?, "No streams started was expected, but #{subscription.streams.count} found"
end

Проверяет, что потоки не запущены.

def test_assert_no_started_stream
  subscribe
  assert_no_streams
end

perform(action, data = {}) Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 241
def perform(action, data = {})
  check_subscribed!
  subscription.perform_action(data.stringify_keys.merge("action" => action.to_s))
end

Выполнить действие в канале.

ПРИМЕЧАНИЕ: Требуется подписка.

stub_connection(identifiers = {}) Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 219
def stub_connection(identifiers = {})
  @connection = ConnectionStub.new(identifiers)
end

Создать тестовое соединение со следующими идентификаторами:

class ApplicationCable < ActionCable::Connection::Base
  identified_by :user, :token
end

stub_connection(user: users[:john], token: 'my-secret-token')

# File actioncable/lib/action_cable/channel/test_case.rb, line 224
def subscribe(params = {})
  @connection ||= stub_connection
  @subscription = self.class.channel_class.new(connection, CHANNEL_IDENTIFIER, params.with_indifferent_access)
  @subscription.singleton_class.include(ChannelStub)
  @subscription.subscribe_to_channel
  @subscription
end

Подписаться на канал для тестирования. Допустимо передавать параметры подписки в виде Hash.

transmissions() Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 247
def transmissions
  # Return only directly sent message (via #transmit)
  connection.transmissions.map { |data| data["message"] }.compact
end

Возвращает сообщения, переданные в канал

unsubscribe() Показать исходный код

# File actioncable/lib/action_cable/channel/test_case.rb, line 233
def unsubscribe
  check_subscribed!
  subscription.unsubscribe_from_channel
end

Отписаться от тестовой подписки.