in qldbdriver/transaction.go [117:127]
func (executor *transactionExecutor) BufferResult(result Result) (BufferedResult, error) {
bufferedResults := make([][]byte, 0)
for result.Next(executor) {
bufferedResults = append(bufferedResults, result.GetCurrentData())
}
if result.Err() != nil {
return nil, result.Err()
}
return &bufferedResult{bufferedResults, 0, nil, result.GetConsumedIOs(), result.GetTimingInformation()}, nil
}