module Concurrent::Promises::Future::NewChannelIntegration

@!macro warn.edge

Public Instance Methods

then_channel_push(channel) click to toggle source

@param [Channel] channel to push to. @return [Future] a future which is fulfilled after the message is pushed to the channel.

May take a moment if the channel is full.
# 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