Module: Concurrent::Promises::Future::NewChannelIntegration

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

Overview

Note:

Edge Features are under active development and may change frequently.

  • Deprecations are not added before incompatible changes.
  • Edge version: major is always 0, minor bump means incompatible change, patch bump means compatible change.
  • Edge features may also lack tests and documentation.
  • Features developed in concurrent-ruby-edge are expected to move to concurrent-ruby when finalised.

Instance Method Summary collapse

Instance Method Details

#then_channel_push(channel) ⇒ Future

Returns a future which is fulfilled after the message is pushed to the channel. May take a moment if the channel is full.

Parameters:

  • channel (Channel) —

    to push to.

Returns:

  • (Future) —

    a future which is fulfilled after the message is pushed to the channel. May take a moment if the channel is full.



59
60
61
 
# File 'lib/concurrent-ruby-edge/concurrent/edge/promises.rb', line 59

def then_channel_push(channel)
  self.then(channel) { |value, ch| ch.push_op value }.flat_future
end