1 files changed, 31 insertions, 0 deletions
diff --git a/actioncable/test/javascript/src/unit/consumer_test.coffee b/actioncable/test/javascript/src/unit/consumer_test.coffee
new file mode 100644
index 0000000000..d8b1450ad8
--- /dev/null
+++ b/actioncable/test/javascript/src/unit/consumer_test.coffee
@@ -0,0 +1,31 @@
+{module, test} = QUnit
+{testURL, createConsumer} = ActionCable.TestHelpers
+
+module "ActionCable.Consumer", ->
+  test "#connect", (assert) ->
+    done = assert.async()
+
+    createConsumer testURL, (consumer, server) ->
+      server.on "connection", ->
+        clients = server.clients()
+        assert.equal clients.length, 1
+        assert.equal clients[0].readyState, WebSocket.OPEN
+        done()
+
+      consumer.connect()
+
+  test "#disconnect", (assert) ->
+    done = assert.async()
+
+    createConsumer testURL, (consumer, server) ->
+      server.on "connection", ->
+        clients = server.clients()
+        assert.equal clients.length, 1
+
+        clients[0].addEventListener "close", (event) ->
+          assert.equal event.type, "close"
+          done()
+
+        consumer.disconnect()
+
+      consumer.connect()