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

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Included In: `Promises::Future`, `Promises::ResolvableFuture`
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.

Parameters:

Returns:

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

[ GitHub ]

# 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