Module: Concurrent::Promises::Future::ActorIntegration

Included in:
Concurrent::Promises::Future
Defined in:
lib/concurrent-ruby-edge/concurrent/edge/promises.rb

Instance Method Summary collapse

Instance Method Details

#then_ask(actor) ⇒ Future

Asks the actor with its value.

Returns:

  • (Future)

    new future with the response form the actor



14
15
16
# File 'lib/concurrent-ruby-edge/concurrent/edge/promises.rb', line 14

def then_ask(actor)
  self.then(actor) { |v, a| a.ask_op(v) }.flat
end