function queryError(requestId, err, next)
{
  // We only 1 return error per query so it may have been removed from the list
  if ( requestId in requestsPending )
  {
    // Remove request
    delete requestsPending[requestId]
    // Send back error
    next(err)
  }
}
// Called when a query finishes with an error
Called when a query finishes with an error
Called when a query finishes with an error
function queryError(requestId, err, next)
{
  if ( requestId in requestsPending )
  {
    delete requestsPending[requestId]
    next(err)
  }
}
function queryError ( requestId , err , next ) { if ( requestId in requestsPending ) { delete requestsPending [ requestId ] next ( err ) } }
Called when a query finishes with an error
Called when a query finishes with an error
// We only 1 return error per query so it may have been removed from the list // Remove request // Send back error