class StatelyDB::Transaction::Transaction

def request_list_responses(req)

Other tags:
    Api: - private

Returns:
  • (::Stately::Db::ListToken) - the token

Other tags:
    Yieldparam: resp - the response

Parameters:
  • req (::Stately::Db::TransactionRequest) -- the request to send
def request_list_responses(req)
  request_only(req)
  token = nil
  loop do
    resp = @incoming_responses.next.list_results
    if resp.finished
      raw_token = resp.finished.token
      token = StatelyDB::Token.new(token_data: raw_token.token_data,
                                   can_continue: raw_token.can_continue,
                                   can_sync: raw_token.can_sync,
                                   schema_version_id: raw_token.schema_version_id)
      break
    end
    yield resp
  end
  token
end