Remove legacy iterator protocol use in Zotero.DB

chrome/content/zotero/xpcom/db.js

@@ -584,22 +584,18 @@ Zotero.DBConnection.prototype.queryAsync = Zotero.Promise.coroutine(function* (s
 		}
 		var failed = false;
 		if (options && options.onRow) {
-			// Errors in onRow don't stop the query unless StopIteration is thrown
+			// Wrap onRow to cancel iteration by default and reject the promise
-			onRow = function (row) {
+			// on any error, which Sqlite.jsm does not do.
+			onRow = function (row, cancel) {
 				try {
-					options.onRow(row);
+					options.onRow(row, () => {
+						Zotero.debug("Query cancelled", 3);
+						cancel();
+					});
 				}
 				catch (e) {
-					// If the onRow throws a StopIteration, stop gracefully
+					failed = e;
-					if (e instanceof StopIteration) {
+					cancel();
-						Zotero.debug("Query cancelled", 3);
-					}
-					// Otherwise, mark the promise as rejected, which Sqlite.jsm doesn't do
-					// on a StopIteration by default
-					else {
-						failed = e;
-					}
-					throw StopIteration;
 				}
 			}
 		}

test/tests/dbTest.js

@@ -151,16 +151,16 @@ describe("Zotero.DB", function() {
 			assert.equal(e.message, "Failed");
 		});
 		
-		it("should stop gracefully if onRow throws a StopIteration", function* () {
+		it("should stop gracefully if onRow is cancelled", function* () {
 			var i = 0;
 			var rows = [];
 			yield Zotero.DB.queryAsync(
 				"SELECT * FROM " + tmpTable,
 				false,
 				{
-					onRow: function (row) {
+					onRow: function (row, cancel) {
 						if (i > 0) {
-							throw StopIteration;
+							return cancel();
 						}
 						rows.push(row.getResultByIndex(0));
 						i++;