test/channel/stream_test.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

require 'test_helper'
require 'stubs/test_connection'

class ActionCable::Channel::StreamTest < ActiveSupport::TestCase
  Room = Struct.new(:id)

  class ChatChannel < ActionCable::Channel::Base
    def subscribed
      @room = Room.new params[:id]
      stream_from "test_room_#{@room.id}"
    end
  end

  setup do
    @connection = TestConnection.new
  end

  test "streaming start and stop" do
    @connection.expects(:pubsub).returns mock().tap { |m| m.expects(:subscribe) }
    channel = ChatChannel.new @connection, "{id: 1}", { id: 1 }

    @connection.expects(:pubsub).returns mock().tap { |m| m.expects(:unsubscribe_proc) }
    channel.unsubscribe_from_channel
  end
end