We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3fd5f42 commit c9944c4Copy full SHA for c9944c4
lib/concurrent/actor/utils/pool.rb
@@ -42,7 +42,7 @@ def on_message(message)
42
else
43
Envelope.new(envelope.message, Concurrent.future, envelope.sender, envelope.sender)
44
end
45
- envelope.future.on_completion! { @balancer << :subscribe }
+ envelope.future.on_completion! &lambda { |balancer, success, value, reason| balancer << :subscribe }.curry[@balancer]
46
redirect @balancer, envelope_to_redirect
47
48
0 commit comments