module ActionCable::Channel::TestCase::Behavior
Constants
- CHANNEL_IDENTIFIER
Public Instance Methods
assert_broadcast_on(stream_or_object, *args)
click to toggle source
Calls superclass method
ActionCable::TestHelper#assert_broadcast_on
# File 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
assert_broadcasts(stream_or_object, *args)
click to toggle source
Enhance TestHelper
assertions to handle non-String broadcastings
Calls superclass method
ActionCable::TestHelper#assert_broadcasts
# File lib/action_cable/channel/test_case.rb, line 254 def assert_broadcasts(stream_or_object, *args) super(broadcasting_for(stream_or_object), *args) end
assert_has_stream(stream)
click to toggle source
Asserts that the specified stream has been started.
def test_assert_started_stream subscribe assert_has_stream 'messages' end
# File 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
assert_has_stream_for(object)
click to toggle source
Asserts that the specified stream for a model has started.
def test_assert_started_stream_for subscribe id: 42 assert_has_stream_for User.find(42) end
# File lib/action_cable/channel/test_case.rb, line 291 def assert_has_stream_for(object) assert_has_stream(broadcasting_for(object)) end
assert_no_streams()
click to toggle source
Asserts that no streams have been started.
def test_assert_no_started_stream subscribe assert_no_streams end
# File 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
perform(action, data = {})
click to toggle source
Perform action on a channel.
NOTE: Must be subscribed.
# File 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 = {})
click to toggle source
Setup test connection with the specified identifiers:
class ApplicationCable < ActionCable::Connection::Base identified_by :user, :token end stub_connection(user: users[:john], token: 'my-secret-token')
# File lib/action_cable/channel/test_case.rb, line 219 def stub_connection(identifiers = {}) @connection = ConnectionStub.new(identifiers) end
subscribe(params = {})
click to toggle source
Subscribe to the channel under test. Optionally pass subscription parameters as a Hash.
# File 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
transmissions()
click to toggle source
Returns messages transmitted into channel
# File 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()
click to toggle source
Unsubscribe the subscription under test.
# File lib/action_cable/channel/test_case.rb, line 233 def unsubscribe check_subscribed! subscription.unsubscribe_from_channel end
Private Instance Methods
broadcasting_for(stream_or_object)
click to toggle source
# File lib/action_cable/channel/test_case.rb, line 300 def broadcasting_for(stream_or_object) return stream_or_object if stream_or_object.is_a?(String) self.class.channel_class.broadcasting_for(stream_or_object) end
check_subscribed!()
click to toggle source
# File lib/action_cable/channel/test_case.rb, line 296 def check_subscribed! raise "Must be subscribed!" if subscription.nil? || subscription.rejected? end