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

Included in:: Concurrent::Promises::Future

Defined in:: lib/concurrent-ruby-edge/concurrent/edge/promises.rb

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.

Parameters:

channel (Channel) —

to push to.

Returns:

(Future) —

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