DBClientCursor::nextSafe() throws an exception if the next doc contains "$err" as the first field - probably better to keep track of when/if the error flag is thrown by a request for more data.