module Concurrent::Promises::Future::NewChannelIntegration
@!macro warn.edge
Public Instance Methods
then_push_channel(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-edge/concurrent/edge/promises.rb, line 150 def then_push_channel(channel) self.then { |value| channel.push value }.flat_future end