class Cql::Client::Pipeline

@private

Public Class Methods

new(async_statement) click to toggle source
# File lib/cql/client/prepared_statement.rb, line 291
def initialize(async_statement)
  @async_statement = async_statement
  @futures = []
end

Public Instance Methods

execute(*args) click to toggle source
# File lib/cql/client/prepared_statement.rb, line 296
def execute(*args)
  @futures << @async_statement.execute(*args)
end
value() click to toggle source
# File lib/cql/client/prepared_statement.rb, line 300
def value
  Future.all(*@futures).value
end