aboutsummaryrefslogtreecommitdiffstats
path: root/actioncable/lib/action_cable/connection
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2016-01-08 20:09:25 +0100
committerDavid Heinemeier Hansson <david@loudthinking.com>2016-01-08 20:09:25 +0100
commit36fe3015644284dfbd7716c1d844dd8ad68b88c2 (patch)
treed111571f1a34efba019097993b074123c943e93e /actioncable/lib/action_cable/connection
parent3b7ccadfc1c8dfec61af898167e1300b17f5cf25 (diff)
downloadrails-36fe3015644284dfbd7716c1d844dd8ad68b88c2.tar.gz
rails-36fe3015644284dfbd7716c1d844dd8ad68b88c2.tar.bz2
rails-36fe3015644284dfbd7716c1d844dd8ad68b88c2.zip
Revert "Move async execution from celluloid to concurrent-ruby"
Diffstat (limited to 'actioncable/lib/action_cable/connection')
-rw-r--r--actioncable/lib/action_cable/connection/base.rb2
1 files changed, 1 insertions, 1 deletions
diff --git a/actioncable/lib/action_cable/connection/base.rb b/actioncable/lib/action_cable/connection/base.rb
index a8cfdf90f3..977856d656 100644
--- a/actioncable/lib/action_cable/connection/base.rb
+++ b/actioncable/lib/action_cable/connection/base.rb
@@ -103,7 +103,7 @@ module ActionCable
# Invoke a method on the connection asynchronously through the pool of thread workers.
def send_async(method, *arguments)
- worker_pool.async_invoke(self, method, *arguments)
+ worker_pool.async.invoke(self, method, *arguments)
end
# Return a basic hash of statistics for the connection keyed with `identifier`, `started_at`, and `subscriptions`.