123456789_123456789_123456789_123456789_123456789_

Class: Redis::MultiFuture

Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Future
Instance Chain:
self, Future
Inherits: Redis::Future
Defined in: lib/redis/pipeline.rb

Constant Summary

Future - Inherited

FutureNotReady

Class Method Summary

Future - Inherited

.new

Instance Method Summary

Future - Inherited

#_set, #_set_unless_error, #class, #inspect, #is_a?, #value

Constructor Details

.new(futures) ⇒ MultiFuture

[ GitHub ] 

  


# File 'lib/redis/pipeline.rb', line 119



def initialize(futures)
  @futures = futures
  @command = [:exec]
  @object = FutureNotReady
end


  







Instance Method Details



  

    #_set(replies)  
  

  [ GitHub ]


  

  


# File 'lib/redis/pipeline.rb', line 125



def _set(replies)
  @object = if replies && !replies.is_a?(::StandardError)
    @futures.map.with_index do |future, index|
      future._set(replies[index])
      future.value
    end
  elsif replies.is_a?(::StandardError)
    @futures.each { |future| future._set_unless_error(replies) }
    replies
  else
    replies
  end
end