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 be39a0a commit 83a9ea6Copy full SHA for 83a9ea6
lib/concurrent/actor/utils/pool.rb
@@ -43,7 +43,7 @@ def on_message(message)
43
envelope_to_redirect = if envelope.future
44
envelope
45
else
46
- Envelope.new(envelope.message, Concurrent::Promises.future, envelope.sender, envelope.address)
+ Envelope.new(envelope.message, Promises.resolvable_future, envelope.sender, envelope.address)
47
end
48
envelope_to_redirect.future.on_fulfillment! { @balancer << :subscribe } # TODO check safety of @balancer reading
49
redirect @balancer, envelope_to_redirect
0 commit comments