diff options
| author | Matthew Draper <matthew@trebex.net> | 2016-01-28 18:46:14 +1030 |
|---|---|---|
| committer | Matthew Draper <matthew@trebex.net> | 2016-01-30 03:46:37 +1030 |
| commit | 786ed1b3ad8eeddb911211b67031016730ed55c8 (patch) | |
| tree | 47ffe90c1ae2cb7c1552e47a10dcb25900ef9486 /actioncable/test/client | |
| parent | ce37de4a19447fc89d2d16f15ba9314fba30d47e (diff) | |
| download | rails-786ed1b3ad8eeddb911211b67031016730ed55c8.tar.gz rails-786ed1b3ad8eeddb911211b67031016730ed55c8.tar.bz2 rails-786ed1b3ad8eeddb911211b67031016730ed55c8.zip | |
Handle more IO errors (especially, ECONNRESET)
Also, address the possibility of the listen thread dying and needing to
be respawned. As a bonus, we now defer construction of the thread until
we are first given something to monitor.
Diffstat (limited to 'actioncable/test/client')
| -rw-r--r-- | actioncable/test/client/echo_channel.rb | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/actioncable/test/client/echo_channel.rb b/actioncable/test/client/echo_channel.rb index 9a54080d4d..63e35f194a 100644 --- a/actioncable/test/client/echo_channel.rb +++ b/actioncable/test/client/echo_channel.rb @@ -7,6 +7,11 @@ class EchoChannel < ActionCable::Channel::Base 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 |