class Redis::MultiFuture

Public Class Methods

new(futures) click to toggle source
# File lib/redis/pipeline.rb, line 114
def initialize(futures)
  @futures = futures
  @command = [:exec]
  @object = FutureNotReady
end

Public Instance Methods

_set(replies) click to toggle source
# File lib/redis/pipeline.rb, line 120
def _set(replies)
  @object = if replies
    @futures.map.with_index do |future, index|
      future._set(replies[index])
      future.value
    end
  else
    replies
  end
end