module Concurrent::Promises::FactoryMethods::OldChannelIntegration

@!visibility private

Public Instance Methods

select(*channels) click to toggle source

only proof of concept @return [Future]

# File lib-edge/concurrent/edge/old_channel_integration.rb, line 13
def select(*channels)
  # TODO (pitr-ch 26-Mar-2016): re-do, has to be non-blocking
  future do
    # noinspection RubyArgCount
    Channel.select do |s|
      channels.each do |ch|
        s.take(ch) { |value| [value, ch] }
      end
    end
  end
end