Class: Voltdb::AllPartitionProcCallback

Inherits:
Object
  • Object
show all
Includes:
Java::OrgVoltdbClient::AllPartitionProcedureCallback
Defined in:
lib/voltdb/callbacks.rb

Instance Method Summary collapse

Constructor Details

#initialize(&block) ⇒ AllPartitionProcCallback

Returns a new instance of AllPartitionProcCallback.



35
36
37
 
# File 'lib/voltdb/callbacks.rb', line 35

def initialize(&block)
  @block = block
end

Instance Method Details

#client_callback(client_response_with_partition_key) ⇒ Object 



39
40
41
42
43
44
45
46
 
# File 'lib/voltdb/callbacks.rb', line 39

def client_callback(client_response_with_partition_key)
  response = client_response_with_partition_key.map do |partition|
    partition.response.extend(ClientResponseUtils)
    partition
  end

  @block.call(response)
end