Contents

require 'concurrent/promises'

module Concurrent
  module Promises
    module FactoryMethods

      # @!visibility private

      module OldChannelIntegration

        # @!visibility private

        # only proof of concept
        # @return [Future]
        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
      end

      include OldChannelIntegration
    end

    class Future < AbstractEventFuture

      # @!visibility private

      module OldChannelIntegration

        # @!visibility private

        # Zips with selected value form the supplied channels
        # @return [Future]
        def then_select(*channels)
          future = Concurrent::Promises.select(*channels)
          ZipFuturesPromise.new_blocked_by2(self, future, @DefaultExecutor).future
        end

        # @note may block
        # @note only proof of concept
        def then_put(channel)
          on_fulfillment_using(:io, channel) { |value, channel| channel.put value }
        end
      end

      include OldChannelIntegration
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
concurrent-ruby-edge-0.7.2	lib/concurrent-ruby-edge/concurrent/edge/old_channel_integration.rb