test(executeOperation): test throwing of errors in executeOperation

lib/utils.js

@@ -436,7 +436,6 @@ const executeOperation = (topology, operation, args, options) => {
       return operation.apply(null, args);
     } catch (e) {
       handler(e);
-      throw e;
     }
   });
 };

test/unit/execute_operation_tests.js

@@ -0,0 +1,62 @@
+'use strict';
+
+const expect = require('chai').expect;
+const executeOperation = require('../../lib/utils').executeOperation;
+
+describe('executeOperation', function() {
+  it('should call callback with errors on throw errors, and rethrow error', function() {
+    const expectedError = new Error('THIS IS AN ERROR');
+    let callbackError, caughtError;
+
+    const topology = {
+      logicalSessionTimeoutMinutes: null,
+      s: {
+        promiseLibrary: Promise
+      }
+    };
+    const operation = () => {
+      throw expectedError;
+    };
+
+    const callback = err => (callbackError = err);
+    const options = { skipSessions: true };
+
+    try {
+      executeOperation(topology, operation, [{}, callback], options);
+    } catch (e) {
+      caughtError = e;
+    }
+
+    expect(callbackError).to.equal(expectedError);
+    expect(caughtError).to.equal(expectedError);
+  });
+
+  it('should reject promise with errors on throw errors, and rethrow error', function(done) {
+    const expectedError = new Error('THIS IS AN ERROR');
+    let callbackError;
+
+    const topology = {
+      logicalSessionTimeoutMinutes: null,
+      s: {
+        promiseLibrary: Promise
+      }
+    };
+    const operation = () => {
+      throw expectedError;
+    };
+
+    const callback = err => (callbackError = err);
+    const options = { skipSessions: true };
+
+    executeOperation(topology, operation, [{}, null], options).then(null, callback);
+
+    setTimeout(() => {
+      try {
+        expect(callbackError).to.equal(expectedError);
+        done();
+      } catch (e) {
+        done(e);
+      }
+    });
+  });
+});