module Concurrent::Promises::Future::OldChannelIntegration
@!visibility private
Public Instance Methods
Source
# 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
@note may block @note only proof of concept
Source
# 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
Zips with selected value form the supplied channels @return [Future]