diff options
| author | Matthew Draper <matthew@trebex.net> | 2016-01-30 04:21:16 +1030 |
|---|---|---|
| committer | Matthew Draper <matthew@trebex.net> | 2016-01-30 04:21:16 +1030 |
| commit | 703ddadafee29c86ca5be499a80802fbea70a64f (patch) | |
| tree | fd7558a9a27970c7d494a6768bac25361a808cd6 /actioncable/test/client | |
| parent | c8818dfcdf9e92364745000eefe46132a43f8700 (diff) | |
| parent | 4d01cd1545a00ed6f96d6cb658a590afd36e1871 (diff) | |
| download | rails-703ddadafee29c86ca5be499a80802fbea70a64f.tar.gz rails-703ddadafee29c86ca5be499a80802fbea70a64f.tar.bz2 rails-703ddadafee29c86ca5be499a80802fbea70a64f.zip | |
Merge pull request #23305 from matthewd/concurrent-take-2
EventMachine -> concurrent-ruby, take two
Diffstat (limited to 'actioncable/test/client')
| -rw-r--r-- | actioncable/test/client/echo_channel.rb | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/actioncable/test/client/echo_channel.rb b/actioncable/test/client/echo_channel.rb new file mode 100644 index 0000000000..63e35f194a --- /dev/null +++ b/actioncable/test/client/echo_channel.rb @@ -0,0 +1,18 @@ +class EchoChannel < ActionCable::Channel::Base + def subscribed + stream_from "global" + end + + def ding(data) + transmit(dong: data['message']) + end + + def delay(data) + sleep 1 + transmit(dong: data['message']) + end + + def bulk(data) + ActionCable.server.broadcast "global", wide: data['message'] + end +end |