From 633c92eae865e957121e08de634aeee11a8b3992 Mon Sep 17 00:00:00 2001
From: RaindropsSys <contact@minteck.org>
Date: Mon, 24 Apr 2023 14:03:36 +0200
Subject: Updated 18 files, added 1692 files and deleted
 includes/system/compare.inc (automated)

---
 .../matrix/node_modules/retry/example/stop.js      | 40 ++++++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 includes/external/matrix/node_modules/retry/example/stop.js

(limited to 'includes/external/matrix/node_modules/retry/example/stop.js')

diff --git a/includes/external/matrix/node_modules/retry/example/stop.js b/includes/external/matrix/node_modules/retry/example/stop.js
new file mode 100644
index 0000000..e1ceafe
--- /dev/null
+++ b/includes/external/matrix/node_modules/retry/example/stop.js
@@ -0,0 +1,40 @@
+var retry = require('../lib/retry');
+
+function attemptAsyncOperation(someInput, cb) {
+  var opts = {
+    retries: 2,
+    factor: 2,
+    minTimeout: 1 * 1000,
+    maxTimeout: 2 * 1000,
+    randomize: true
+  };
+  var operation = retry.operation(opts);
+
+  operation.attempt(function(currentAttempt) {
+    failingAsyncOperation(someInput, function(err, result) {
+
+      if (err && err.message === 'A fatal error') {
+        operation.stop();
+        return cb(err);
+      }
+
+      if (operation.retry(err)) {
+        return;
+      }
+
+      cb(operation.mainError(), operation.errors(), result);
+    });
+  });
+}
+
+attemptAsyncOperation('test input', function(err, errors, result) {
+  console.warn('err:');
+  console.log(err);
+
+  console.warn('result:');
+  console.log(result);
+});
+
+function failingAsyncOperation(input, cb) {
+  return setImmediate(cb.bind(null, new Error('A fatal error')));
+}
-- 
cgit