diff options
author | Vladimir Dementyev <dementiev.vm@gmail.com> | 2018-08-19 19:06:30 -0400 |
---|---|---|
committer | Vladimir Dementyev <dementiev.vm@gmail.com> | 2018-08-19 19:06:30 -0400 |
commit | f7dd2d67d6a8b74f2762be51dff4f96983175aee (patch) | |
tree | b19c182aca42342ac0c8c075ad4904e5cdb07080 /actioncable/test | |
parent | 44007c07098a3c633180881cae9285da4622e63f (diff) | |
download | rails-f7dd2d67d6a8b74f2762be51dff4f96983175aee.tar.gz rails-f7dd2d67d6a8b74f2762be51dff4f96983175aee.tar.bz2 rails-f7dd2d67d6a8b74f2762be51dff4f96983175aee.zip |
Add Action Cable test adapter
Diffstat (limited to 'actioncable/test')
-rw-r--r-- | actioncable/test/subscription_adapter/test_adapter_test.rb | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/actioncable/test/subscription_adapter/test_adapter_test.rb b/actioncable/test/subscription_adapter/test_adapter_test.rb new file mode 100644 index 0000000000..3fe07adb4a --- /dev/null +++ b/actioncable/test/subscription_adapter/test_adapter_test.rb @@ -0,0 +1,47 @@ +# frozen_string_literal: true + +require "test_helper" +require_relative "common" + +class ActionCable::SubscriptionAdapter::TestTest < ActionCable::TestCase + include CommonSubscriptionAdapterTest + + def setup + super + + @tx_adapter.shutdown + @tx_adapter = @rx_adapter + end + + def cable_config + { adapter: "test" } + end + + test "#broadcast stores messages for streams" do + @tx_adapter.broadcast("channel", "payload") + @tx_adapter.broadcast("channel2", "payload2") + + assert_equal ["payload"], @tx_adapter.broadcasts("channel") + assert_equal ["payload2"], @tx_adapter.broadcasts("channel2") + end + + test "#clear_messages deletes recorded broadcasts for the channel" do + @tx_adapter.broadcast("channel", "payload") + @tx_adapter.broadcast("channel2", "payload2") + + @tx_adapter.clear_messages("channel") + + assert_equal [], @tx_adapter.broadcasts("channel") + assert_equal ["payload2"], @tx_adapter.broadcasts("channel2") + end + + test "#clear deletes all recorded broadcasts" do + @tx_adapter.broadcast("channel", "payload") + @tx_adapter.broadcast("channel2", "payload2") + + @tx_adapter.clear + + assert_equal [], @tx_adapter.broadcasts("channel") + assert_equal [], @tx_adapter.broadcasts("channel2") + end +end |