module Concurrent::Promises::FactoryMethods::NewChannelIntegration

@!macro warn.edge

Public Instance Methods

select_channel(*channels) click to toggle source

Selects a channel which is ready to be read from. @param [Channel] channels @return [Future] a future which is fulfilled with pair [channel, message] when one of the channels is

available for reading
# File lib-edge/concurrent/edge/promises.rb, line 167
def select_channel(*channels)
  probe = Promises.resolvable_future
  channels.each { |ch| ch.pop_for_select probe }
  probe
end