diff options
| author | Matthew Draper <matthew@trebex.net> | 2016-01-14 15:59:32 +1030 |
|---|---|---|
| committer | Jon Moss <me@jonathanmoss.me> | 2016-01-18 18:59:01 -0500 |
| commit | 05d753ff31548377dec587ed1aeef03d92ec535f (patch) | |
| tree | e1bb94c366fad6721dbab407e4b3a04db2920ac7 /actioncable/lib | |
| parent | 2815db356977b506f63d155aecf71ee010a64c62 (diff) | |
| download | rails-05d753ff31548377dec587ed1aeef03d92ec535f.tar.gz rails-05d753ff31548377dec587ed1aeef03d92ec535f.tar.bz2 rails-05d753ff31548377dec587ed1aeef03d92ec535f.zip | |
Don't execute callbacks on our main listener thread
Diffstat (limited to 'actioncable/lib')
| -rw-r--r-- | actioncable/lib/action_cable/storage_adapter/postgres.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/actioncable/lib/action_cable/storage_adapter/postgres.rb b/actioncable/lib/action_cable/storage_adapter/postgres.rb index 07c2c7ce6a..8b4c0ef29f 100644 --- a/actioncable/lib/action_cable/storage_adapter/postgres.rb +++ b/actioncable/lib/action_cable/storage_adapter/postgres.rb @@ -57,7 +57,7 @@ module ActionCable pg_conn.wait_for_notify(1) do |chan, pid, message| @subscribers[chan].each do |callback| - callback.call(message) + ::EM.next_tick { callback.call(message) } end end end |