为何ActionCable广播在测试环境中无法正常工作？

核心原因 #

在ActionCable Channel测试环境中，直接在测试代码里调用subscription.stream_from并传入回调块的方式不会自动触发消息处理——测试框架的订阅对象不会主动分发广播消息，必须手动触发处理流程，或者将流的定义放在通道类的生命周期方法中。

方案1：规范通道类定义（推荐） #

将stream_from的回调逻辑移到通道类的subscribed方法中，这是ActionCable的标准用法：

# app/channels/test_channel.rb
class TestChannel < ApplicationCable::Channel
  def subscribed
    stream_from "something" do |message|
      @received_message = message
      # 如需向客户端发送消息，可添加 transmit message
    end
  end

  attr_reader :received_message
end

修改测试用例，手动触发广播消息处理并验证结果：

require "test_helper"

class TestChannelTest < ActionCable::Channel::TestCase
  test "receives broadcast messages" do
    subscribe

    assert subscription.confirmed?

    ActionCable.server.broadcast("something", 100)
    # 手动触发消息处理，测试环境不会自动执行此步骤
    subscription.send(:process_broadcast, "something", 100)

    assert_equal 100, subscription.received_message
  end
end

方案2：测试内直接绑定消息处理（无需修改通道类） #

如果不想改动通道类，可直接通过订阅对象的on_message回调捕获广播：

require "test_helper"

class TestChannelTest < ActionCable::Channel::TestCase
  test "it works at all" do
    subscribe

    assert subscription.confirmed?

    last_message = nil
    # 绑定消息处理回调，筛选目标流的消息
    subscription.on_message do |message|
      last_message = message if message["identifier"] == "something"
    end

    ActionCable.server.broadcast("something", 100)
    # 手动触发广播消息处理
    subscription.send(:process_broadcast, "something", 100)

    assert_equal 100, last_message
  end
end

关键提示 #

测试环境下ActionCable不会异步自动处理广播，必须调用process_broadcast方法手动触发消息的分发与回调执行。

内容的提问来源于stack exchange，提问作者rmosolgo