module Concurrent::Promises::Future::NewChannelIntegration
@!macro warn.edge
Public Instance Methods
Source
# 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
@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.