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 toconcurrent-ruby
when finalised.
Instance Method Summary collapse
-
#then_channel_push(channel) ⇒ Future
A future which is fulfilled after the message is pushed to the channel.
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.
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 |