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-edge/concurrent/edge/old_channel_integration.rb, line 46 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-edge/concurrent/edge/old_channel_integration.rb, line 39 def then_select(*channels) future = Concurrent::Promises.select(*channels) ZipFuturesPromise.new_blocked_by2(self, future, @DefaultExecutor).future end