const std::string& index,

ResultResponse** response) {

ResponseMap::const_iterator it = responses.find(index);

if (it == responses.end() || it->second->opcode() != CQL_OPCODE_RESULT) {

return false;

}

*response = static_cast<ResultResponse*>(it->second.get());

return true;

if (has_errors_or_timeouts_) return;

responses_[index] = SharedRefPtr<Response>();

SharedRefPtr<InternalHandler> handler(new InternalHandler(this, new QueryRequest(query), index));

remaining_++;

if (!connection_->write(handler.get())) {

on_error(CASS_ERROR_LIB_NO_STREAMS, "No more streams available");

}