module Concurrent::Promises::Future::OldChannelIntegration

@!visibility private

Public Instance Methods

then_put(channel) click to toggle source

@note may block @note only proof of concept

# File lib/concurrent-ruby-edge/concurrent/edge/old_channel_integration.rb, line 48
def then_put(channel)
  on_fulfillment_using(:io, channel) { |value, channel| channel.put value }
end
then_select(*channels) click to toggle source

Zips with selected value form the suplied channels @return [Future]

# File lib/concurrent-ruby-edge/concurrent/edge/old_channel_integration.rb, line 41
def then_select(*channels)
  future = Concurrent::Promises.select(*channels)
  ZipFuturesPromise.new_blocked_by2(self, future, @DefaultExecutor).future
end