From ee90c8c101a29eb31d56e739e41454655d929d64 Mon Sep 17 00:00:00 2001
From: pubkey <8926560+pubkey@users.noreply.github.com>
Date: Thu, 16 Dec 2021 00:15:39 +0100
Subject: [PATCH] 4.8.0

---
 dist/es5node/leader-election.js   | 56 +++++++++++++++++++++----------
 dist/esbrowser/leader-election.js | 56 +++++++++++++++++++++----------
 dist/esnode/leader-election.js    | 56 +++++++++++++++++++++----------
 dist/lib/browser.js               | 56 +++++++++++++++++++++----------
 dist/lib/browser.min.js           |  2 +-
 dist/lib/leader-election.js       | 56 +++++++++++++++++++++----------
 docs/e2e.js                       | 56 +++++++++++++++++++++----------
 docs/iframe.js                    | 56 +++++++++++++++++++++----------
 docs/index.js                     | 56 +++++++++++++++++++++----------
 docs/leader-iframe.js             | 56 +++++++++++++++++++++----------
 docs/worker.js                    | 56 +++++++++++++++++++++----------
 package.json                      |  2 +-
 12 files changed, 382 insertions(+), 182 deletions(-)

diff --git a/dist/es5node/leader-election.js b/dist/es5node/leader-election.js
index 38448aaa..5c3a9715 100644
--- a/dist/es5node/leader-election.js
+++ b/dist/es5node/leader-election.js
@@ -33,8 +33,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -69,7 +67,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -144,10 +143,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -155,7 +167,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -208,12 +220,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -247,7 +253,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -257,18 +262,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/dist/esbrowser/leader-election.js b/dist/esbrowser/leader-election.js
index 1cba9ff2..c8c9cbb4 100644
--- a/dist/esbrowser/leader-election.js
+++ b/dist/esbrowser/leader-election.js
@@ -24,8 +24,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -60,7 +58,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -135,10 +134,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([sleep(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([sleep(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -146,7 +158,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([sleep(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([sleep(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -199,12 +211,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -238,7 +244,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -248,18 +253,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return sleep(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/dist/esnode/leader-election.js b/dist/esnode/leader-election.js
index 1cba9ff2..c8c9cbb4 100644
--- a/dist/esnode/leader-election.js
+++ b/dist/esnode/leader-election.js
@@ -24,8 +24,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -60,7 +58,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -135,10 +134,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([sleep(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([sleep(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -146,7 +158,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([sleep(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([sleep(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -199,12 +211,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -238,7 +244,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -248,18 +253,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return sleep(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/dist/lib/browser.js b/dist/lib/browser.js
index e4f400ad..f2586943 100644
--- a/dist/lib/browser.js
+++ b/dist/lib/browser.js
@@ -401,8 +401,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -437,7 +435,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -512,10 +511,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -523,7 +535,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -576,12 +588,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -615,7 +621,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -625,18 +630,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/dist/lib/browser.min.js b/dist/lib/browser.min.js
index 2ec55e94..4f9e70dd 100644
--- a/dist/lib/browser.min.js
+++ b/dist/lib/browser.min.js
@@ -1 +1 @@
-!function r(o,i,s){function a(t,e){if(!i[t]){if(!o[t]){var n="function"==typeof require&&require;if(!e&&n)return n(t,!0);if(u)return u(t,!0);throw(n=new Error("Cannot find module '"+t+"'")).code="MODULE_NOT_FOUND",n}n=i[t]={exports:{}},o[t][0].call(n.exports,function(e){return a(o[t][1][e]||e)},n,n.exports,r,o,i,s)}return i[t].exports}for(var u="function"==typeof require&&require,e=0;e<s.length;e++)a(s[e]);return a}({1:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.OPEN_BROADCAST_CHANNELS=n.BroadcastChannel=void 0,n.clearNodeFolder=function(e){e=(0,i.fillOptionsWithDefaults)(e);e=(0,r.chooseMethod)(e);return"node"===e.type?e.clearNodeFolder().then(function(){return!0}):o.PROMISE_RESOLVED_FALSE},n.enforceOptions=function(e){u=e};var o=e("./util.js"),r=e("./method-chooser.js"),i=e("./options.js"),s=new Set;n.OPEN_BROADCAST_CHANNELS=s;function a(e,t){var n;this.id=c++,s.add(this),this.name=e,u&&(t=u),this.options=(0,i.fillOptionsWithDefaults)(t),this.method=(0,r.chooseMethod)(this.options),this._iL=!1,this._onML=null,this._addEL={message:[],internal:[]},this._uMP=new Set,this._befC=[],this._prepP=null,t=(n=this).method.create(n.name,n.options),(0,o.isPromise)(t)?(n._prepP=t).then(function(e){n._state=e}):n._state=t}var u,c=0;function l(t,e,n){var r={time:t.method.microSeconds(),type:e,data:n};return(t._prepP||o.PROMISE_RESOLVED_VOID).then(function(){var e=t.method.postMessage(t._state,r);return t._uMP.add(e),e.catch().then(function(){return t._uMP.delete(e)}),e})}function d(e){return 0<e._addEL.message.length||0<e._addEL.internal.length}function f(e,t,n){e._addEL[t].push(n),function(e){{var t,n;!e._iL&&d(e)&&(t=function(t){e._addEL[t.type].forEach(function(e){t.time>=e.time&&e.fn(t.data)})},n=e.method.microSeconds(),e._prepP?e._prepP.then(function(){e._iL=!0,e.method.onMessage(e._state,t,n)}):(e._iL=!0,e.method.onMessage(e._state,t,n)))}}(e)}function h(e,t,n){e._addEL[t]=e._addEL[t].filter(function(e){return e!==n}),function(e){{var t;e._iL&&!d(e)&&(e._iL=!1,t=e.method.microSeconds(),e.method.onMessage(e._state,null,t))}}(e)}(n.BroadcastChannel=a)._pubkey=!0,a.prototype={postMessage:function(e){if(this.closed)throw new Error("BroadcastChannel.postMessage(): Cannot post message after channel has closed");return l(this,"message",e)},postInternal:function(e){return l(this,"internal",e)},set onmessage(e){var t={time:this.method.microSeconds(),fn:e};h(this,"message",this._onML),e&&"function"==typeof e?(this._onML=t,f(this,"message",t)):this._onML=null},addEventListener:function(e,t){var n=this.method.microSeconds();f(this,e,{time:n,fn:t})},removeEventListener:function(e,t){var n=this._addEL[e].find(function(e){return e.fn===t});h(this,e,n)},close:function(){var e=this;if(!this.closed){s.delete(this),this.closed=!0;var t=this._prepP||o.PROMISE_RESOLVED_VOID;return this._onML=null,this._addEL.message=[],t.then(function(){return Promise.all(Array.from(e._uMP))}).then(function(){return Promise.all(e._befC.map(function(e){return e()}))}).then(function(){return e.method.close(e._state)})}},get type(){return this.method.type},get isClosed(){return this.closed}}},{"./method-chooser.js":6,"./options.js":11,"./util.js":12}],2:[function(e,t,n){"use strict";var r=e("./index.es5.js"),e=r.BroadcastChannel,r=r.createLeaderElection;window.BroadcastChannel2=e,window.createLeaderElection=r},{"./index.es5.js":3}],3:[function(e,t,n){"use strict";e=e("./index.js");t.exports={BroadcastChannel:e.BroadcastChannel,createLeaderElection:e.createLeaderElection,clearNodeFolder:e.clearNodeFolder,enforceOptions:e.enforceOptions,beLeader:e.beLeader}},{"./index.js":4}],4:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),Object.defineProperty(n,"BroadcastChannel",{enumerable:!0,get:function(){return r.BroadcastChannel}}),Object.defineProperty(n,"OPEN_BROADCAST_CHANNELS",{enumerable:!0,get:function(){return r.OPEN_BROADCAST_CHANNELS}}),Object.defineProperty(n,"beLeader",{enumerable:!0,get:function(){return o.beLeader}}),Object.defineProperty(n,"clearNodeFolder",{enumerable:!0,get:function(){return r.clearNodeFolder}}),Object.defineProperty(n,"createLeaderElection",{enumerable:!0,get:function(){return o.createLeaderElection}}),Object.defineProperty(n,"enforceOptions",{enumerable:!0,get:function(){return r.enforceOptions}});var r=e("./broadcast-channel"),o=e("./leader-election")},{"./broadcast-channel":1,"./leader-election":5}],5:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.beLeader=u,n.createLeaderElection=function(e,t){if(e._leaderElector)throw new Error("BroadcastChannel already has a leader-elector");t=function(e,t){e=e||{};(e=JSON.parse(JSON.stringify(e))).fallbackInterval||(e.fallbackInterval=3e3);e.responseTime||(e.responseTime=t.method.averageResponseTime(t.options));return e}(t,e);var n=new o(e,t);return e._befC.push(function(){return n.die()}),e._leaderElector=n};var s=e("./util.js"),r=e("unload"),o=function(e,t){var n=this;this.broadcastChannel=e,this._options=t,this.isLeader=!1,this.hasLeader=!1,this.isDead=!1,this.token=(0,s.randomToken)(),this._aplQ=s.PROMISE_RESOLVED_VOID,this._aplQC=0,this._unl=[],this._lstns=[],this._invs=[],this._dpL=function(){},this._dpLC=!1;function r(e){"leader"===e.context&&("death"===e.action&&(n.hasLeader=!1),"tell"===e.action&&(n.hasLeader=!0))}this.broadcastChannel.addEventListener("internal",r),this._lstns.push(r)};function a(e,t){t={context:"leader",action:t,token:e.token};return e.broadcastChannel.postInternal(t)}function u(t){t.isLeader=!0,t.hasLeader=!0;var e=(0,r.add)(function(){return t.die()});t._unl.push(e);function n(e){"leader"===e.context&&"apply"===e.action&&a(t,"tell"),"leader"!==e.context||"tell"!==e.action||t._dpLC||(t._dpLC=!0,t._dpL(),a(t,"tell"))}return t.broadcastChannel.addEventListener("internal",n),t._lstns.push(n),a(t,"tell")}o.prototype={applyOnce:function(){var i=this;if(this.isLeader)return(0,s.sleep)(0,!0);if(this.isDead)return(0,s.sleep)(0,!1);if(1<this._aplQC)return this._aplQ;function e(){if(i.isLeader)return s.PROMISE_RESOLVED_TRUE;function e(e){"leader"===e.context&&e.token!=i.token&&(o.push(e),"apply"===e.action&&e.token>i.token&&t(),"tell"===e.action&&(t(),i.hasLeader=!0))}var t,n=!1,r=new Promise(function(e){t=function(){n=!0,e()}}),o=[];return i.broadcastChannel.addEventListener("internal",e),a(i,"apply").then(function(){return Promise.race([(0,s.sleep)(i._options.responseTime/2),r.then(function(){return Promise.reject(new Error)})])}).then(function(){return a(i,"apply")}).then(function(){return Promise.race([(0,s.sleep)(i._options.responseTime/2),r.then(function(){return Promise.reject(new Error)})])}).catch(function(){}).then(function(){return i.broadcastChannel.removeEventListener("internal",e),!n&&u(i).then(function(){return!0})})}return this._aplQC=this._aplQC+1,this._aplQ=this._aplQ.then(e).then(function(){i._aplQC=i._aplQC-1}),this._aplQ.then(function(){return i.isLeader})},awaitLeadership:function(){return this._aLP||(this._aLP=function(i){if(i.isLeader)return s.PROMISE_RESOLVED_VOID;return new Promise(function(e){var t=!1;function n(){t||(t=!0,clearInterval(r),i.broadcastChannel.removeEventListener("internal",o),e(!0))}i.applyOnce().then(function(){i.isLeader&&n()});var r=setInterval(function(){i.applyOnce().then(function(){i.isLeader&&n()})},i._options.fallbackInterval);i._invs.push(r);var o=function(e){"leader"===e.context&&"death"===e.action&&(i.hasLeader=!1,i.applyOnce().then(function(){i.isLeader&&n()}))};i.broadcastChannel.addEventListener("internal",o),i._lstns.push(o)})}(this)),this._aLP},set onduplicate(e){this._dpL=e},die:function(){var t=this;return this._lstns.forEach(function(e){return t.broadcastChannel.removeEventListener("internal",e)}),this._lstns=[],this._invs.forEach(function(e){return clearInterval(e)}),this._invs=[],this._unl.forEach(function(e){return e.remove()}),this._unl=[],this.isLeader&&(this.hasLeader=!1,this.isLeader=!1),this.isDead=!0,a(this,"death")}}},{"./util.js":12,unload:20}],6:[function(e,t,n){"use strict";var r=e("@babel/runtime/helpers/interopRequireDefault");e("@babel/runtime/helpers/typeof");Object.defineProperty(n,"__esModule",{value:!0}),n.chooseMethod=function(t){var e=[].concat(t.methods,u).filter(Boolean);if(t.type){if("simulate"===t.type)return s.default;var n=e.find(function(e){return e.type===t.type});if(n)return n;throw new Error("method-type "+t.type+" not found")}t.webWorkerSupport||a.isNode||(e=e.filter(function(e){return"idb"!==e.type}));e=e.find(function(e){return e.canBeUsed()});{if(e)return e;throw new Error("No useable method found in "+JSON.stringify(u.map(function(e){return e.type})))}};var o=r(e("./methods/native.js")),i=r(e("./methods/indexed-db.js")),n=r(e("./methods/localstorage.js")),s=r(e("./methods/simulate.js")),a=e("./util");var u=[o.default,i.default,n.default]},{"./methods/indexed-db.js":7,"./methods/localstorage.js":8,"./methods/native.js":9,"./methods/simulate.js":10,"./util":12,"@babel/runtime/helpers/interopRequireDefault":13,"@babel/runtime/helpers/typeof":14}],7:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.averageResponseTime=y,n.canBeUsed=w,n.cleanOldMessages=p,n.close=b,n.create=m,n.createDatabase=c,n.default=void 0,n.getAllMessages=function(e){var n=e.transaction(a).objectStore(a),r=[];return new Promise(function(t){n.openCursor().onsuccess=function(e){e=e.target.result;e?(r.push(e.value),e.continue()):t(r)}})},n.getIdb=u,n.getMessagesHigherThan=d,n.getOldMessages=h,n.microSeconds=void 0,n.onMessage=g,n.postMessage=_,n.removeMessageById=f,n.type=void 0,n.writeMessage=l;var o=e("../util.js"),i=e("oblivious-set"),s=e("../options"),e=o.microSeconds;n.microSeconds=e;var r="pubkey.broadcast-channel-0-",a="messages";function u(){if("undefined"!=typeof indexedDB)return indexedDB;if("undefined"!=typeof window){if(void 0!==window.mozIndexedDB)return window.mozIndexedDB;if(void 0!==window.webkitIndexedDB)return window.webkitIndexedDB;if(void 0!==window.msIndexedDB)return window.msIndexedDB}return!1}function c(e){var n=u().open(r+e,1);return n.onupgradeneeded=function(e){e.target.result.createObjectStore(a,{keyPath:"id",autoIncrement:!0})},new Promise(function(e,t){n.onerror=function(e){return t(e)},n.onsuccess=function(){e(n.result)}})}function l(e,t,n){var r={uuid:t,time:(new Date).getTime(),data:n},o=e.transaction([a],"readwrite");return new Promise(function(e,t){o.oncomplete=function(){return e()},o.onerror=function(e){return t(e)},o.objectStore(a).add(r)})}function d(e,n){var r=e.transaction(a).objectStore(a),o=[];return new Promise(function(t){(function(){try{var e=IDBKeyRange.bound(n+1,1/0);return r.openCursor(e)}catch(e){return r.openCursor()}})().onsuccess=function(e){e=e.target.result;e?e.value.id<n+1?e.continue(n+1):(o.push(e.value),e.continue()):t(o)}})}function f(e,t){var n=e.transaction([a],"readwrite").objectStore(a).delete(t);return new Promise(function(e){n.onsuccess=function(){return e()}})}function h(e,t){var r=(new Date).getTime()-t,o=e.transaction(a).objectStore(a),i=[];return new Promise(function(n){o.openCursor().onsuccess=function(e){var t,e=e.target.result;e&&(t=e.value).time<r?(i.push(t),e.continue()):n(i)}})}function p(t,e){return h(t,e).then(function(e){return Promise.all(e.map(function(e){return f(t,e.id)}))})}function m(n,r){return r=(0,s.fillOptionsWithDefaults)(r),c(n).then(function(e){var t={closed:!1,lastCursorId:0,channelName:n,options:r,uuid:(0,o.randomToken)(),eMIs:new i.ObliviousSet(2*r.idb.ttl),writeBlockPromise:o.PROMISE_RESOLVED_VOID,messagesCallback:null,readQueuePromises:[],db:e};return e.onclose=function(){t.closed=!0,r.idb.onclose&&r.idb.onclose()},function e(t){if(t.closed)return;v(t).then(function(){return(0,o.sleep)(t.options.idb.fallbackInterval)}).then(function(){return e(t)})}(t),t})}function v(n){return!n.closed&&n.messagesCallback?d(n.db,n.lastCursorId).then(function(e){return e.filter(function(e){return!!e}).map(function(e){return e.id>n.lastCursorId&&(n.lastCursorId=e.id),e}).filter(function(e){return t=n,(e=e).uuid!==t.uuid&&(!t.eMIs.has(e.id)&&!(e.data.time<t.messagesCallbackTime));var t}).sort(function(e,t){return e.time-t.time}).forEach(function(e){n.messagesCallback&&(n.eMIs.add(e.id),n.messagesCallback(e.data))}),o.PROMISE_RESOLVED_VOID}):o.PROMISE_RESOLVED_VOID}function b(e){e.closed=!0,e.db.close()}function _(e,t){return e.writeBlockPromise=e.writeBlockPromise.then(function(){return l(e.db,e.uuid,t)}).then(function(){0===(0,o.randomInt)(0,10)&&p(e.db,e.options.idb.ttl)}),e.writeBlockPromise}function g(e,t,n){e.messagesCallbackTime=n,e.messagesCallback=t,v(e)}function w(){return!o.isNode&&!!u()}function y(e){return 2*e.idb.fallbackInterval}n.type="idb",n.default={create:m,close:b,onMessage:g,postMessage:_,canBeUsed:w,type:"idb",averageResponseTime:y,microSeconds:e}},{"../options":11,"../util.js":12,"oblivious-set":17}],8:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.addStorageEventListener=d,n.averageResponseTime=b,n.canBeUsed=v,n.close=p,n.create=h,n.default=void 0,n.getLocalStorage=u,n.microSeconds=void 0,n.onMessage=m,n.postMessage=l,n.removeStorageEventListener=f,n.storageKey=c,n.type=void 0;var i=e("oblivious-set"),s=e("../options"),a=e("../util"),r=a.microSeconds;n.microSeconds=r;var o="pubkey.broadcastChannel-",e="localstorage";function u(){var e;if("undefined"==typeof window)return null;try{e=window.localStorage,e=window["ie8-eventlistener/storage"]||window.localStorage}catch(e){}return e}function c(e){return o+e}function l(o,i){return new Promise(function(r){(0,a.sleep)().then(function(){var e=c(o.channelName),t={token:(0,a.randomToken)(),time:(new Date).getTime(),data:i,uuid:o.uuid},n=JSON.stringify(t);u().setItem(e,n);t=document.createEvent("Event");t.initEvent("storage",!0,!0),t.key=e,t.newValue=n,window.dispatchEvent(t),r()})})}function d(e,t){function n(e){e.key===r&&t(JSON.parse(e.newValue))}var r=o+e;return window.addEventListener("storage",n),n}function f(e){window.removeEventListener("storage",e)}function h(e,t){if(t=(0,s.fillOptionsWithDefaults)(t),!v())throw new Error("BroadcastChannel: localstorage cannot be used");var n=(0,a.randomToken)(),r=new i.ObliviousSet(t.localstorage.removeTimeout),o={channelName:e,uuid:n,eMIs:r};return o.listener=d(e,function(e){o.messagesCallback&&e.uuid!==n&&e.token&&!r.has(e.token)&&(e.data.time&&e.data.time<o.messagesCallbackTime||(r.add(e.token),o.messagesCallback(e.data)))}),o}function p(e){f(e.listener)}function m(e,t,n){e.messagesCallbackTime=n,e.messagesCallback=t}function v(){if(a.isNode)return!1;var e=u();if(!e)return!1;try{var t="__broadcastchannel_check";e.setItem(t,"works"),e.removeItem(t)}catch(e){return!1}return!0}function b(){var e=navigator.userAgent.toLowerCase();return e.includes("safari")&&!e.includes("chrome")?240:120}n.type=e,n.default={create:h,close:p,onMessage:m,postMessage:l,canBeUsed:v,type:e,averageResponseTime:b,microSeconds:r}},{"../options":11,"../util":12,"oblivious-set":17}],9:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.averageResponseTime=c,n.canBeUsed=u,n.close=i,n.create=o,n.microSeconds=n.default=void 0,n.onMessage=a,n.postMessage=s,n.type=void 0;var r=e("../util"),e=r.microSeconds;n.microSeconds=e;function o(e){var t={messagesCallback:null,bc:new BroadcastChannel(e),subFns:[]};return t.bc.onmessage=function(e){t.messagesCallback&&t.messagesCallback(e.data)},t}function i(e){e.bc.close(),e.subFns=[]}function s(e,t){try{return e.bc.postMessage(t,!1),r.PROMISE_RESOLVED_VOID}catch(e){return Promise.reject(e)}}function a(e,t){e.messagesCallback=t}function u(){if(r.isNode&&"undefined"==typeof window)return!1;if("function"!=typeof BroadcastChannel)return!1;if(BroadcastChannel._pubkey)throw new Error("BroadcastChannel: Do not overwrite window.BroadcastChannel with this module, this is not a polyfill");return!0}function c(){return 150}n.type="native",n.default={create:o,close:i,onMessage:a,postMessage:s,canBeUsed:u,type:"native",averageResponseTime:c,microSeconds:e}},{"../util":12}],10:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.averageResponseTime=l,n.canBeUsed=c,n.close=s,n.create=i,n.microSeconds=n.default=void 0,n.onMessage=u,n.postMessage=a,n.type=void 0;var r=e("../util").microSeconds;n.microSeconds=r;e="simulate";n.type=e;var o=new Set;function i(e){e={name:e,messagesCallback:null};return o.add(e),e}function s(e){o.delete(e)}function a(t,n){return new Promise(function(e){return setTimeout(function(){Array.from(o).filter(function(e){return e.name===t.name}).filter(function(e){return e!==t}).filter(function(e){return!!e.messagesCallback}).forEach(function(e){return e.messagesCallback(n)}),e()},5)})}function u(e,t){e.messagesCallback=t}function c(){return!0}function l(){return 5}n.default={create:i,close:s,onMessage:u,postMessage:a,canBeUsed:c,type:e,averageResponseTime:l,microSeconds:r}},{"../util":12}],11:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.fillOptionsWithDefaults=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{},t=JSON.parse(JSON.stringify(e));void 0===t.webWorkerSupport&&(t.webWorkerSupport=!0);t.idb||(t.idb={});t.idb.ttl||(t.idb.ttl=45e3);t.idb.fallbackInterval||(t.idb.fallbackInterval=150);e.idb&&"function"==typeof e.idb.onclose&&(t.idb.onclose=e.idb.onclose);t.localstorage||(t.localstorage={});t.localstorage.removeTimeout||(t.localstorage.removeTimeout=6e4);e.methods&&(t.methods=e.methods);t.node||(t.node={});t.node.ttl||(t.node.ttl=12e4);t.node.maxParallelWrites||(t.node.maxParallelWrites=2048);void 0===t.node.useFastPath&&(t.node.useFastPath=!0);return t}},{}],12:[function(e,t,o){!function(r){!function(){"use strict";Object.defineProperty(o,"__esModule",{value:!0}),o.isNode=o.PROMISE_RESOLVED_VOID=o.PROMISE_RESOLVED_TRUE=o.PROMISE_RESOLVED_FALSE=void 0,o.isPromise=function(e){return!(!e||"function"!=typeof e.then)},o.microSeconds=function(){var e=(new Date).getTime();return e===t?1e3*e+ ++n:(n=0,1e3*(t=e))},o.randomInt=function(e,t){return Math.floor(Math.random()*(t-e+1)+e)},o.randomToken=function(){return Math.random().toString(36).substring(2)},o.sleep=function(t,n){t=t||0;return new Promise(function(e){return setTimeout(function(){return e(n)},t)})};var e=Promise.resolve(!1);o.PROMISE_RESOLVED_FALSE=e;e=Promise.resolve(!0);o.PROMISE_RESOLVED_TRUE=e;e=Promise.resolve();o.PROMISE_RESOLVED_VOID=e;var t=0,n=0;e="[object process]"===Object.prototype.toString.call(void 0!==r?r:0);o.isNode=e}.call(this)}.call(this,e("_process"))},{_process:18}],13:[function(e,t,n){t.exports=function(e){return e&&e.__esModule?e:{default:e}},t.exports.default=t.exports,t.exports.__esModule=!0},{}],14:[function(e,t,n){function r(e){return"function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?t.exports=r=function(e){return typeof e}:t.exports=r=function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},t.exports.default=t.exports,t.exports.__esModule=!0,r(e)}t.exports=r,t.exports.default=t.exports,t.exports.__esModule=!0},{}],15:[function(e,t,n){},{}],16:[function(e,t,n){t.exports=!1},{}],17:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.now=n.removeTooOldValues=n.ObliviousSet=void 0;var r=(o.prototype.has=function(e){return this.set.has(e)},o.prototype.add=function(e){var t=this;this.timeMap.set(e,s()),this.set.add(e),setTimeout(function(){i(t)},0)},o.prototype.clear=function(){this.set.clear(),this.timeMap.clear()},o);function o(e){this.ttl=e,this.set=new Set,this.timeMap=new Map}function i(e){for(var t=s()-e.ttl,n=e.set[Symbol.iterator]();;){var r=n.next().value;if(!r)return;if(!(e.timeMap.get(r)<t))return;e.timeMap.delete(r),e.set.delete(r)}}function s(){return(new Date).getTime()}n.ObliviousSet=r,n.removeTooOldValues=i,n.now=s},{}],18:[function(e,t,n){var r,o,t=t.exports={};function i(){throw new Error("setTimeout has not been defined")}function s(){throw new Error("clearTimeout has not been defined")}function a(t){if(r===setTimeout)return setTimeout(t,0);if((r===i||!r)&&setTimeout)return r=setTimeout,setTimeout(t,0);try{return r(t,0)}catch(e){try{return r.call(null,t,0)}catch(e){return r.call(this,t,0)}}}!function(){try{r="function"==typeof setTimeout?setTimeout:i}catch(e){r=i}try{o="function"==typeof clearTimeout?clearTimeout:s}catch(e){o=s}}();var u,c=[],l=!1,d=-1;function f(){l&&u&&(l=!1,u.length?c=u.concat(c):d=-1,c.length&&h())}function h(){if(!l){var e=a(f);l=!0;for(var t=c.length;t;){for(u=c,c=[];++d<t;)u&&u[d].run();d=-1,t=c.length}u=null,l=!1,function(t){if(o===clearTimeout)return clearTimeout(t);if((o===s||!o)&&clearTimeout)return o=clearTimeout,clearTimeout(t);try{o(t)}catch(e){try{return o.call(null,t)}catch(e){return o.call(this,t)}}}(e)}}function p(e,t){this.fun=e,this.array=t}function m(){}t.nextTick=function(e){var t=new Array(arguments.length-1);if(1<arguments.length)for(var n=1;n<arguments.length;n++)t[n-1]=arguments[n];c.push(new p(e,t)),1!==c.length||l||a(h)},p.prototype.run=function(){this.fun.apply(null,this.array)},t.title="browser",t.browser=!0,t.env={},t.argv=[],t.version="",t.versions={},t.on=m,t.addListener=m,t.once=m,t.off=m,t.removeListener=m,t.removeAllListeners=m,t.emit=m,t.prependListener=m,t.prependOnceListener=m,t.listeners=function(e){return[]},t.binding=function(e){throw new Error("process.binding is not supported")},t.cwd=function(){return"/"},t.chdir=function(e){throw new Error("process.chdir is not supported")},t.umask=function(){return 0}},{}],19:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.default=void 0,n.default={add:function(e){"function"==typeof WorkerGlobalScope&&self instanceof WorkerGlobalScope||"function"==typeof window.addEventListener&&(window.addEventListener("beforeunload",function(){e()},!0),window.addEventListener("unload",function(){e()},!0))}}},{}],20:[function(e,t,n){"use strict";var r=e("@babel/runtime/helpers/interopRequireDefault");Object.defineProperty(n,"__esModule",{value:!0}),n.add=function(e){if(a||(a=!0,i.add(u)),"function"!=typeof e)throw new Error("Listener is no function");return s.add(e),{remove:function(){return s.delete(e)},run:function(){return s.delete(e),e()}}},n.getSize=function(){return s.size},n.removeAll=function(){s.clear()},n.runAll=u;var o=r(e("detect-node")),n=r(e("./browser.js")),e=r(e("./node.js")),i=(o.default?e:n).default,s=new Set,a=!1;function u(){var t=[];return s.forEach(function(e){t.push(e()),s.delete(e)}),Promise.all(t)}},{"./browser.js":19,"./node.js":15,"@babel/runtime/helpers/interopRequireDefault":13,"detect-node":16}]},{},[2]);
\ No newline at end of file
+!function r(o,i,s){function a(t,e){if(!i[t]){if(!o[t]){var n="function"==typeof require&&require;if(!e&&n)return n(t,!0);if(u)return u(t,!0);throw(n=new Error("Cannot find module '"+t+"'")).code="MODULE_NOT_FOUND",n}n=i[t]={exports:{}},o[t][0].call(n.exports,function(e){return a(o[t][1][e]||e)},n,n.exports,r,o,i,s)}return i[t].exports}for(var u="function"==typeof require&&require,e=0;e<s.length;e++)a(s[e]);return a}({1:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.OPEN_BROADCAST_CHANNELS=n.BroadcastChannel=void 0,n.clearNodeFolder=function(e){e=(0,i.fillOptionsWithDefaults)(e);e=(0,r.chooseMethod)(e);return"node"===e.type?e.clearNodeFolder().then(function(){return!0}):o.PROMISE_RESOLVED_FALSE},n.enforceOptions=function(e){u=e};var o=e("./util.js"),r=e("./method-chooser.js"),i=e("./options.js"),s=new Set;n.OPEN_BROADCAST_CHANNELS=s;function a(e,t){var n;this.id=c++,s.add(this),this.name=e,u&&(t=u),this.options=(0,i.fillOptionsWithDefaults)(t),this.method=(0,r.chooseMethod)(this.options),this._iL=!1,this._onML=null,this._addEL={message:[],internal:[]},this._uMP=new Set,this._befC=[],this._prepP=null,t=(n=this).method.create(n.name,n.options),(0,o.isPromise)(t)?(n._prepP=t).then(function(e){n._state=e}):n._state=t}var u,c=0;function l(t,e,n){var r={time:t.method.microSeconds(),type:e,data:n};return(t._prepP||o.PROMISE_RESOLVED_VOID).then(function(){var e=t.method.postMessage(t._state,r);return t._uMP.add(e),e.catch().then(function(){return t._uMP.delete(e)}),e})}function d(e){return 0<e._addEL.message.length||0<e._addEL.internal.length}function f(e,t,n){e._addEL[t].push(n),function(e){{var t,n;!e._iL&&d(e)&&(t=function(t){e._addEL[t.type].forEach(function(e){t.time>=e.time&&e.fn(t.data)})},n=e.method.microSeconds(),e._prepP?e._prepP.then(function(){e._iL=!0,e.method.onMessage(e._state,t,n)}):(e._iL=!0,e.method.onMessage(e._state,t,n)))}}(e)}function h(e,t,n){e._addEL[t]=e._addEL[t].filter(function(e){return e!==n}),function(e){{var t;e._iL&&!d(e)&&(e._iL=!1,t=e.method.microSeconds(),e.method.onMessage(e._state,null,t))}}(e)}(n.BroadcastChannel=a)._pubkey=!0,a.prototype={postMessage:function(e){if(this.closed)throw new Error("BroadcastChannel.postMessage(): Cannot post message after channel has closed");return l(this,"message",e)},postInternal:function(e){return l(this,"internal",e)},set onmessage(e){var t={time:this.method.microSeconds(),fn:e};h(this,"message",this._onML),e&&"function"==typeof e?(this._onML=t,f(this,"message",t)):this._onML=null},addEventListener:function(e,t){var n=this.method.microSeconds();f(this,e,{time:n,fn:t})},removeEventListener:function(e,t){var n=this._addEL[e].find(function(e){return e.fn===t});h(this,e,n)},close:function(){var e=this;if(!this.closed){s.delete(this),this.closed=!0;var t=this._prepP||o.PROMISE_RESOLVED_VOID;return this._onML=null,this._addEL.message=[],t.then(function(){return Promise.all(Array.from(e._uMP))}).then(function(){return Promise.all(e._befC.map(function(e){return e()}))}).then(function(){return e.method.close(e._state)})}},get type(){return this.method.type},get isClosed(){return this.closed}}},{"./method-chooser.js":6,"./options.js":11,"./util.js":12}],2:[function(e,t,n){"use strict";var r=e("./index.es5.js"),e=r.BroadcastChannel,r=r.createLeaderElection;window.BroadcastChannel2=e,window.createLeaderElection=r},{"./index.es5.js":3}],3:[function(e,t,n){"use strict";e=e("./index.js");t.exports={BroadcastChannel:e.BroadcastChannel,createLeaderElection:e.createLeaderElection,clearNodeFolder:e.clearNodeFolder,enforceOptions:e.enforceOptions,beLeader:e.beLeader}},{"./index.js":4}],4:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),Object.defineProperty(n,"BroadcastChannel",{enumerable:!0,get:function(){return r.BroadcastChannel}}),Object.defineProperty(n,"OPEN_BROADCAST_CHANNELS",{enumerable:!0,get:function(){return r.OPEN_BROADCAST_CHANNELS}}),Object.defineProperty(n,"beLeader",{enumerable:!0,get:function(){return o.beLeader}}),Object.defineProperty(n,"clearNodeFolder",{enumerable:!0,get:function(){return r.clearNodeFolder}}),Object.defineProperty(n,"createLeaderElection",{enumerable:!0,get:function(){return o.createLeaderElection}}),Object.defineProperty(n,"enforceOptions",{enumerable:!0,get:function(){return r.enforceOptions}});var r=e("./broadcast-channel"),o=e("./leader-election")},{"./broadcast-channel":1,"./leader-election":5}],5:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.beLeader=l,n.createLeaderElection=function(e,t){if(e._leaderElector)throw new Error("BroadcastChannel already has a leader-elector");t=function(e,t){e=e||{};(e=JSON.parse(JSON.stringify(e))).fallbackInterval||(e.fallbackInterval=3e3);e.responseTime||(e.responseTime=t.method.averageResponseTime(t.options));return e}(t,e);var n=new o(e,t);return e._befC.push(function(){return n.die()}),e._leaderElector=n};var u=e("./util.js"),r=e("unload"),o=function(e,t){var n=this;this.broadcastChannel=e,this._options=t,this.isLeader=!1,this.hasLeader=!1,this.isDead=!1,this.token=(0,u.randomToken)(),this._aplQ=u.PROMISE_RESOLVED_VOID,this._aplQC=0,this._unl=[],this._lstns=[],this._dpL=function(){},this._dpLC=!1;function r(e){"leader"===e.context&&("death"===e.action&&(n.hasLeader=!1),"tell"===e.action&&(n.hasLeader=!0))}this.broadcastChannel.addEventListener("internal",r),this._lstns.push(r)};function c(e,t){t={context:"leader",action:t,token:e.token};return e.broadcastChannel.postInternal(t)}function l(t){t.isLeader=!0,t.hasLeader=!0;var e=(0,r.add)(function(){return t.die()});t._unl.push(e);function n(e){"leader"===e.context&&"apply"===e.action&&c(t,"tell"),"leader"!==e.context||"tell"!==e.action||t._dpLC||(t._dpLC=!0,t._dpL(),c(t,"tell"))}return t.broadcastChannel.addEventListener("internal",n),t._lstns.push(n),c(t,"tell")}o.prototype={applyOnce:function(s){var a=this;if(this.isLeader)return(0,u.sleep)(0,!0);if(this.isDead)return(0,u.sleep)(0,!1);if(1<this._aplQC)return this._aplQ;function e(){if(a.isLeader)return u.PROMISE_RESOLVED_TRUE;function e(e){"leader"===e.context&&e.token!=a.token&&(o.push(e),"apply"===e.action&&e.token>a.token&&t(),"tell"===e.action&&(t(),a.hasLeader=!0))}var t,n=!1,r=new Promise(function(e){t=function(){n=!0,e()}}),o=[];a.broadcastChannel.addEventListener("internal",e);var i=s?4*a._options.responseTime:a._options.responseTime;return c(a,"apply").then(function(){return Promise.race([(0,u.sleep)(i),r.then(function(){return Promise.reject(new Error)})])}).then(function(){return c(a,"apply")}).then(function(){return Promise.race([(0,u.sleep)(i),r.then(function(){return Promise.reject(new Error)})])}).catch(function(){}).then(function(){return a.broadcastChannel.removeEventListener("internal",e),!n&&l(a).then(function(){return!0})})}return this._aplQC=this._aplQC+1,this._aplQ=this._aplQ.then(e).then(function(){a._aplQC=a._aplQC-1}),this._aplQ.then(function(){return a.isLeader})},awaitLeadership:function(){return this._aLP||(this._aLP=function(o){if(o.isLeader)return u.PROMISE_RESOLVED_VOID;return new Promise(function(e){var t=!1;function n(){t||(t=!0,o.broadcastChannel.removeEventListener("internal",r),e(!0))}o.applyOnce().then(function(){o.isLeader&&n()}),function e(){return(0,u.sleep)(o._options.fallbackInterval).then(function(){if(!o.isDead&&!t)return o.isLeader?void n():o.applyOnce(!0).then(function(){(o.isLeader?n:e)()})})}();var r=function(e){"leader"===e.context&&"death"===e.action&&(o.hasLeader=!1,o.applyOnce().then(function(){o.isLeader&&n()}))};o.broadcastChannel.addEventListener("internal",r),o._lstns.push(r)})}(this)),this._aLP},set onduplicate(e){this._dpL=e},die:function(){var t=this;return this._lstns.forEach(function(e){return t.broadcastChannel.removeEventListener("internal",e)}),this._lstns=[],this._unl.forEach(function(e){return e.remove()}),this._unl=[],this.isLeader&&(this.hasLeader=!1,this.isLeader=!1),this.isDead=!0,c(this,"death")}}},{"./util.js":12,unload:20}],6:[function(e,t,n){"use strict";var r=e("@babel/runtime/helpers/interopRequireDefault");e("@babel/runtime/helpers/typeof");Object.defineProperty(n,"__esModule",{value:!0}),n.chooseMethod=function(t){var e=[].concat(t.methods,u).filter(Boolean);if(t.type){if("simulate"===t.type)return s.default;var n=e.find(function(e){return e.type===t.type});if(n)return n;throw new Error("method-type "+t.type+" not found")}t.webWorkerSupport||a.isNode||(e=e.filter(function(e){return"idb"!==e.type}));e=e.find(function(e){return e.canBeUsed()});{if(e)return e;throw new Error("No useable method found in "+JSON.stringify(u.map(function(e){return e.type})))}};var o=r(e("./methods/native.js")),i=r(e("./methods/indexed-db.js")),n=r(e("./methods/localstorage.js")),s=r(e("./methods/simulate.js")),a=e("./util");var u=[o.default,i.default,n.default]},{"./methods/indexed-db.js":7,"./methods/localstorage.js":8,"./methods/native.js":9,"./methods/simulate.js":10,"./util":12,"@babel/runtime/helpers/interopRequireDefault":13,"@babel/runtime/helpers/typeof":14}],7:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.averageResponseTime=y,n.canBeUsed=w,n.cleanOldMessages=p,n.close=b,n.create=m,n.createDatabase=c,n.default=void 0,n.getAllMessages=function(e){var n=e.transaction(a).objectStore(a),r=[];return new Promise(function(t){n.openCursor().onsuccess=function(e){e=e.target.result;e?(r.push(e.value),e.continue()):t(r)}})},n.getIdb=u,n.getMessagesHigherThan=d,n.getOldMessages=h,n.microSeconds=void 0,n.onMessage=g,n.postMessage=_,n.removeMessageById=f,n.type=void 0,n.writeMessage=l;var o=e("../util.js"),i=e("oblivious-set"),s=e("../options"),e=o.microSeconds;n.microSeconds=e;var r="pubkey.broadcast-channel-0-",a="messages";function u(){if("undefined"!=typeof indexedDB)return indexedDB;if("undefined"!=typeof window){if(void 0!==window.mozIndexedDB)return window.mozIndexedDB;if(void 0!==window.webkitIndexedDB)return window.webkitIndexedDB;if(void 0!==window.msIndexedDB)return window.msIndexedDB}return!1}function c(e){var n=u().open(r+e,1);return n.onupgradeneeded=function(e){e.target.result.createObjectStore(a,{keyPath:"id",autoIncrement:!0})},new Promise(function(e,t){n.onerror=function(e){return t(e)},n.onsuccess=function(){e(n.result)}})}function l(e,t,n){var r={uuid:t,time:(new Date).getTime(),data:n},o=e.transaction([a],"readwrite");return new Promise(function(e,t){o.oncomplete=function(){return e()},o.onerror=function(e){return t(e)},o.objectStore(a).add(r)})}function d(e,n){var r=e.transaction(a).objectStore(a),o=[];return new Promise(function(t){(function(){try{var e=IDBKeyRange.bound(n+1,1/0);return r.openCursor(e)}catch(e){return r.openCursor()}})().onsuccess=function(e){e=e.target.result;e?e.value.id<n+1?e.continue(n+1):(o.push(e.value),e.continue()):t(o)}})}function f(e,t){var n=e.transaction([a],"readwrite").objectStore(a).delete(t);return new Promise(function(e){n.onsuccess=function(){return e()}})}function h(e,t){var r=(new Date).getTime()-t,o=e.transaction(a).objectStore(a),i=[];return new Promise(function(n){o.openCursor().onsuccess=function(e){var t,e=e.target.result;e&&(t=e.value).time<r?(i.push(t),e.continue()):n(i)}})}function p(t,e){return h(t,e).then(function(e){return Promise.all(e.map(function(e){return f(t,e.id)}))})}function m(n,r){return r=(0,s.fillOptionsWithDefaults)(r),c(n).then(function(e){var t={closed:!1,lastCursorId:0,channelName:n,options:r,uuid:(0,o.randomToken)(),eMIs:new i.ObliviousSet(2*r.idb.ttl),writeBlockPromise:o.PROMISE_RESOLVED_VOID,messagesCallback:null,readQueuePromises:[],db:e};return e.onclose=function(){t.closed=!0,r.idb.onclose&&r.idb.onclose()},function e(t){if(t.closed)return;v(t).then(function(){return(0,o.sleep)(t.options.idb.fallbackInterval)}).then(function(){return e(t)})}(t),t})}function v(n){return!n.closed&&n.messagesCallback?d(n.db,n.lastCursorId).then(function(e){return e.filter(function(e){return!!e}).map(function(e){return e.id>n.lastCursorId&&(n.lastCursorId=e.id),e}).filter(function(e){return t=n,(e=e).uuid!==t.uuid&&(!t.eMIs.has(e.id)&&!(e.data.time<t.messagesCallbackTime));var t}).sort(function(e,t){return e.time-t.time}).forEach(function(e){n.messagesCallback&&(n.eMIs.add(e.id),n.messagesCallback(e.data))}),o.PROMISE_RESOLVED_VOID}):o.PROMISE_RESOLVED_VOID}function b(e){e.closed=!0,e.db.close()}function _(e,t){return e.writeBlockPromise=e.writeBlockPromise.then(function(){return l(e.db,e.uuid,t)}).then(function(){0===(0,o.randomInt)(0,10)&&p(e.db,e.options.idb.ttl)}),e.writeBlockPromise}function g(e,t,n){e.messagesCallbackTime=n,e.messagesCallback=t,v(e)}function w(){return!o.isNode&&!!u()}function y(e){return 2*e.idb.fallbackInterval}n.type="idb",n.default={create:m,close:b,onMessage:g,postMessage:_,canBeUsed:w,type:"idb",averageResponseTime:y,microSeconds:e}},{"../options":11,"../util.js":12,"oblivious-set":17}],8:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.addStorageEventListener=d,n.averageResponseTime=b,n.canBeUsed=v,n.close=p,n.create=h,n.default=void 0,n.getLocalStorage=u,n.microSeconds=void 0,n.onMessage=m,n.postMessage=l,n.removeStorageEventListener=f,n.storageKey=c,n.type=void 0;var i=e("oblivious-set"),s=e("../options"),a=e("../util"),r=a.microSeconds;n.microSeconds=r;var o="pubkey.broadcastChannel-",e="localstorage";function u(){var e;if("undefined"==typeof window)return null;try{e=window.localStorage,e=window["ie8-eventlistener/storage"]||window.localStorage}catch(e){}return e}function c(e){return o+e}function l(o,i){return new Promise(function(r){(0,a.sleep)().then(function(){var e=c(o.channelName),t={token:(0,a.randomToken)(),time:(new Date).getTime(),data:i,uuid:o.uuid},n=JSON.stringify(t);u().setItem(e,n);t=document.createEvent("Event");t.initEvent("storage",!0,!0),t.key=e,t.newValue=n,window.dispatchEvent(t),r()})})}function d(e,t){function n(e){e.key===r&&t(JSON.parse(e.newValue))}var r=o+e;return window.addEventListener("storage",n),n}function f(e){window.removeEventListener("storage",e)}function h(e,t){if(t=(0,s.fillOptionsWithDefaults)(t),!v())throw new Error("BroadcastChannel: localstorage cannot be used");var n=(0,a.randomToken)(),r=new i.ObliviousSet(t.localstorage.removeTimeout),o={channelName:e,uuid:n,eMIs:r};return o.listener=d(e,function(e){o.messagesCallback&&e.uuid!==n&&e.token&&!r.has(e.token)&&(e.data.time&&e.data.time<o.messagesCallbackTime||(r.add(e.token),o.messagesCallback(e.data)))}),o}function p(e){f(e.listener)}function m(e,t,n){e.messagesCallbackTime=n,e.messagesCallback=t}function v(){if(a.isNode)return!1;var e=u();if(!e)return!1;try{var t="__broadcastchannel_check";e.setItem(t,"works"),e.removeItem(t)}catch(e){return!1}return!0}function b(){var e=navigator.userAgent.toLowerCase();return e.includes("safari")&&!e.includes("chrome")?240:120}n.type=e,n.default={create:h,close:p,onMessage:m,postMessage:l,canBeUsed:v,type:e,averageResponseTime:b,microSeconds:r}},{"../options":11,"../util":12,"oblivious-set":17}],9:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.averageResponseTime=c,n.canBeUsed=u,n.close=i,n.create=o,n.microSeconds=n.default=void 0,n.onMessage=a,n.postMessage=s,n.type=void 0;var r=e("../util"),e=r.microSeconds;n.microSeconds=e;function o(e){var t={messagesCallback:null,bc:new BroadcastChannel(e),subFns:[]};return t.bc.onmessage=function(e){t.messagesCallback&&t.messagesCallback(e.data)},t}function i(e){e.bc.close(),e.subFns=[]}function s(e,t){try{return e.bc.postMessage(t,!1),r.PROMISE_RESOLVED_VOID}catch(e){return Promise.reject(e)}}function a(e,t){e.messagesCallback=t}function u(){if(r.isNode&&"undefined"==typeof window)return!1;if("function"!=typeof BroadcastChannel)return!1;if(BroadcastChannel._pubkey)throw new Error("BroadcastChannel: Do not overwrite window.BroadcastChannel with this module, this is not a polyfill");return!0}function c(){return 150}n.type="native",n.default={create:o,close:i,onMessage:a,postMessage:s,canBeUsed:u,type:"native",averageResponseTime:c,microSeconds:e}},{"../util":12}],10:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.averageResponseTime=l,n.canBeUsed=c,n.close=s,n.create=i,n.microSeconds=n.default=void 0,n.onMessage=u,n.postMessage=a,n.type=void 0;var r=e("../util").microSeconds;n.microSeconds=r;e="simulate";n.type=e;var o=new Set;function i(e){e={name:e,messagesCallback:null};return o.add(e),e}function s(e){o.delete(e)}function a(t,n){return new Promise(function(e){return setTimeout(function(){Array.from(o).filter(function(e){return e.name===t.name}).filter(function(e){return e!==t}).filter(function(e){return!!e.messagesCallback}).forEach(function(e){return e.messagesCallback(n)}),e()},5)})}function u(e,t){e.messagesCallback=t}function c(){return!0}function l(){return 5}n.default={create:i,close:s,onMessage:u,postMessage:a,canBeUsed:c,type:e,averageResponseTime:l,microSeconds:r}},{"../util":12}],11:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.fillOptionsWithDefaults=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{},t=JSON.parse(JSON.stringify(e));void 0===t.webWorkerSupport&&(t.webWorkerSupport=!0);t.idb||(t.idb={});t.idb.ttl||(t.idb.ttl=45e3);t.idb.fallbackInterval||(t.idb.fallbackInterval=150);e.idb&&"function"==typeof e.idb.onclose&&(t.idb.onclose=e.idb.onclose);t.localstorage||(t.localstorage={});t.localstorage.removeTimeout||(t.localstorage.removeTimeout=6e4);e.methods&&(t.methods=e.methods);t.node||(t.node={});t.node.ttl||(t.node.ttl=12e4);t.node.maxParallelWrites||(t.node.maxParallelWrites=2048);void 0===t.node.useFastPath&&(t.node.useFastPath=!0);return t}},{}],12:[function(e,t,o){!function(r){!function(){"use strict";Object.defineProperty(o,"__esModule",{value:!0}),o.isNode=o.PROMISE_RESOLVED_VOID=o.PROMISE_RESOLVED_TRUE=o.PROMISE_RESOLVED_FALSE=void 0,o.isPromise=function(e){return!(!e||"function"!=typeof e.then)},o.microSeconds=function(){var e=(new Date).getTime();return e===t?1e3*e+ ++n:(n=0,1e3*(t=e))},o.randomInt=function(e,t){return Math.floor(Math.random()*(t-e+1)+e)},o.randomToken=function(){return Math.random().toString(36).substring(2)},o.sleep=function(t,n){t=t||0;return new Promise(function(e){return setTimeout(function(){return e(n)},t)})};var e=Promise.resolve(!1);o.PROMISE_RESOLVED_FALSE=e;e=Promise.resolve(!0);o.PROMISE_RESOLVED_TRUE=e;e=Promise.resolve();o.PROMISE_RESOLVED_VOID=e;var t=0,n=0;e="[object process]"===Object.prototype.toString.call(void 0!==r?r:0);o.isNode=e}.call(this)}.call(this,e("_process"))},{_process:18}],13:[function(e,t,n){t.exports=function(e){return e&&e.__esModule?e:{default:e}},t.exports.default=t.exports,t.exports.__esModule=!0},{}],14:[function(e,t,n){function r(e){return"function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?t.exports=r=function(e){return typeof e}:t.exports=r=function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},t.exports.default=t.exports,t.exports.__esModule=!0,r(e)}t.exports=r,t.exports.default=t.exports,t.exports.__esModule=!0},{}],15:[function(e,t,n){},{}],16:[function(e,t,n){t.exports=!1},{}],17:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.now=n.removeTooOldValues=n.ObliviousSet=void 0;var r=(o.prototype.has=function(e){return this.set.has(e)},o.prototype.add=function(e){var t=this;this.timeMap.set(e,s()),this.set.add(e),setTimeout(function(){i(t)},0)},o.prototype.clear=function(){this.set.clear(),this.timeMap.clear()},o);function o(e){this.ttl=e,this.set=new Set,this.timeMap=new Map}function i(e){for(var t=s()-e.ttl,n=e.set[Symbol.iterator]();;){var r=n.next().value;if(!r)return;if(!(e.timeMap.get(r)<t))return;e.timeMap.delete(r),e.set.delete(r)}}function s(){return(new Date).getTime()}n.ObliviousSet=r,n.removeTooOldValues=i,n.now=s},{}],18:[function(e,t,n){var r,o,t=t.exports={};function i(){throw new Error("setTimeout has not been defined")}function s(){throw new Error("clearTimeout has not been defined")}function a(t){if(r===setTimeout)return setTimeout(t,0);if((r===i||!r)&&setTimeout)return r=setTimeout,setTimeout(t,0);try{return r(t,0)}catch(e){try{return r.call(null,t,0)}catch(e){return r.call(this,t,0)}}}!function(){try{r="function"==typeof setTimeout?setTimeout:i}catch(e){r=i}try{o="function"==typeof clearTimeout?clearTimeout:s}catch(e){o=s}}();var u,c=[],l=!1,d=-1;function f(){l&&u&&(l=!1,u.length?c=u.concat(c):d=-1,c.length&&h())}function h(){if(!l){var e=a(f);l=!0;for(var t=c.length;t;){for(u=c,c=[];++d<t;)u&&u[d].run();d=-1,t=c.length}u=null,l=!1,function(t){if(o===clearTimeout)return clearTimeout(t);if((o===s||!o)&&clearTimeout)return o=clearTimeout,clearTimeout(t);try{o(t)}catch(e){try{return o.call(null,t)}catch(e){return o.call(this,t)}}}(e)}}function p(e,t){this.fun=e,this.array=t}function m(){}t.nextTick=function(e){var t=new Array(arguments.length-1);if(1<arguments.length)for(var n=1;n<arguments.length;n++)t[n-1]=arguments[n];c.push(new p(e,t)),1!==c.length||l||a(h)},p.prototype.run=function(){this.fun.apply(null,this.array)},t.title="browser",t.browser=!0,t.env={},t.argv=[],t.version="",t.versions={},t.on=m,t.addListener=m,t.once=m,t.off=m,t.removeListener=m,t.removeAllListeners=m,t.emit=m,t.prependListener=m,t.prependOnceListener=m,t.listeners=function(e){return[]},t.binding=function(e){throw new Error("process.binding is not supported")},t.cwd=function(){return"/"},t.chdir=function(e){throw new Error("process.chdir is not supported")},t.umask=function(){return 0}},{}],19:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0}),n.default=void 0,n.default={add:function(e){"function"==typeof WorkerGlobalScope&&self instanceof WorkerGlobalScope||"function"==typeof window.addEventListener&&(window.addEventListener("beforeunload",function(){e()},!0),window.addEventListener("unload",function(){e()},!0))}}},{}],20:[function(e,t,n){"use strict";var r=e("@babel/runtime/helpers/interopRequireDefault");Object.defineProperty(n,"__esModule",{value:!0}),n.add=function(e){if(a||(a=!0,i.add(u)),"function"!=typeof e)throw new Error("Listener is no function");return s.add(e),{remove:function(){return s.delete(e)},run:function(){return s.delete(e),e()}}},n.getSize=function(){return s.size},n.removeAll=function(){s.clear()},n.runAll=u;var o=r(e("detect-node")),n=r(e("./browser.js")),e=r(e("./node.js")),i=(o.default?e:n).default,s=new Set,a=!1;function u(){var t=[];return s.forEach(function(e){t.push(e()),s.delete(e)}),Promise.all(t)}},{"./browser.js":19,"./node.js":15,"@babel/runtime/helpers/interopRequireDefault":13,"detect-node":16}]},{},[2]);
\ No newline at end of file
diff --git a/dist/lib/leader-election.js b/dist/lib/leader-election.js
index 38448aaa..5c3a9715 100644
--- a/dist/lib/leader-election.js
+++ b/dist/lib/leader-election.js
@@ -33,8 +33,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -69,7 +67,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -144,10 +143,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -155,7 +167,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -208,12 +220,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -247,7 +253,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -257,18 +262,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/docs/e2e.js b/docs/e2e.js
index b2147f54..f48075c6 100644
--- a/docs/e2e.js
+++ b/docs/e2e.js
@@ -392,8 +392,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -428,7 +426,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -503,10 +502,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -514,7 +526,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -567,12 +579,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -606,7 +612,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -616,18 +621,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/docs/iframe.js b/docs/iframe.js
index 96eb7c34..e5d96778 100644
--- a/docs/iframe.js
+++ b/docs/iframe.js
@@ -392,8 +392,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -428,7 +426,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -503,10 +502,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -514,7 +526,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -567,12 +579,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -606,7 +612,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -616,18 +621,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/docs/index.js b/docs/index.js
index 3e76a8d3..2950ad8e 100644
--- a/docs/index.js
+++ b/docs/index.js
@@ -392,8 +392,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -428,7 +426,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -503,10 +502,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -514,7 +526,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -567,12 +579,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -606,7 +612,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -616,18 +621,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/docs/leader-iframe.js b/docs/leader-iframe.js
index db0d3fe1..f4d30aff 100644
--- a/docs/leader-iframe.js
+++ b/docs/leader-iframe.js
@@ -392,8 +392,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -428,7 +426,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -503,10 +502,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -514,7 +526,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -567,12 +579,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -606,7 +612,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -616,18 +621,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/docs/worker.js b/docs/worker.js
index 922447b0..b7e5d6cd 100644
--- a/docs/worker.js
+++ b/docs/worker.js
@@ -392,8 +392,6 @@ var LeaderElection = function LeaderElection(broadcastChannel, options) {
 
   this._lstns = []; // _listeners
 
-  this._invs = []; // _intervals
-
   this._dpL = function () {}; // onduplicate listener
 
 
@@ -428,7 +426,8 @@ LeaderElection.prototype = {
    * false if not.
    * @async
    */
-  applyOnce: function applyOnce() {
+  applyOnce: function applyOnce( // true if the applyOnce() call came from the fallbackInterval cycle
+  isFromFallbackInterval) {
     var _this2 = this;
 
     if (this.isLeader) {
@@ -503,10 +502,23 @@ LeaderElection.prototype = {
       };
 
       _this2.broadcastChannel.addEventListener('internal', handleMessage);
+      /**
+       * If the applyOnce() call came from the fallbackInterval,
+       * we can assume that the election runs in the background and
+       * not critical process is waiting for it.
+       * When this is true, we give the other intances
+       * more time to answer to messages in the election cycle.
+       * This makes it less likely to elect duplicate leaders.
+       * But also it takes longer which is not a problem because we anyway
+       * run in the background.
+       */
+
+
+      var waitForAnswerTime = isFromFallbackInterval ? _this2._options.responseTime * 4 : _this2._options.responseTime;
 
       var applyPromise = _sendMessage(_this2, 'apply') // send out that this one is applying
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       }) // send again in case another instance was just created
@@ -514,7 +526,7 @@ LeaderElection.prototype = {
         return _sendMessage(_this2, 'apply');
       }) // let others time to respond
       .then(function () {
-        return Promise.race([(0, _util.sleep)(_this2._options.responseTime / 2), stopCriteriaPromise.then(function () {
+        return Promise.race([(0, _util.sleep)(waitForAnswerTime), stopCriteriaPromise.then(function () {
           return Promise.reject(new Error());
         })]);
       })["catch"](function () {}).then(function () {
@@ -567,12 +579,6 @@ LeaderElection.prototype = {
 
     this._lstns = [];
 
-    this._invs.forEach(function (interval) {
-      return clearInterval(interval);
-    });
-
-    this._invs = [];
-
     this._unl.forEach(function (uFn) {
       return uFn.remove();
     });
@@ -606,7 +612,6 @@ function _awaitLeadershipOnce(leaderElector) {
       }
 
       resolved = true;
-      clearInterval(interval);
       leaderElector.broadcastChannel.removeEventListener('internal', whenDeathListener);
       res(true);
     } // try once now
@@ -616,18 +621,33 @@ function _awaitLeadershipOnce(leaderElector) {
       if (leaderElector.isLeader) {
         finish();
       }
-    }); // try on fallbackInterval
+    });
+    /**
+     * Try on fallbackInterval
+     * @recursive
+     */
+
+    var tryOnFallBack = function tryOnFallBack() {
+      return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
+        if (leaderElector.isDead || resolved) {
+          return;
+        }
 
-    var interval = setInterval(function () {
-      leaderElector.applyOnce().then(function () {
         if (leaderElector.isLeader) {
           finish();
+        } else {
+          return leaderElector.applyOnce(true).then(function () {
+            if (leaderElector.isLeader) {
+              finish();
+            } else {
+              tryOnFallBack();
+            }
+          });
         }
       });
-    }, leaderElector._options.fallbackInterval);
-
-    leaderElector._invs.push(interval); // try when other leader dies
+    };
 
+    tryOnFallBack(); // try when other leader dies
 
     var whenDeathListener = function whenDeathListener(msg) {
       if (msg.context === 'leader' && msg.action === 'death') {
diff --git a/package.json b/package.json
index 8e0390bf..a9a2aa2d 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "broadcast-channel",
-  "version": "4.7.1",
+  "version": "4.8.0",
   "description": "A BroadcastChannel that works in New Browsers, Old Browsers, WebWorkers and NodeJs",
   "exports": {
     ".": {