From fcd320c6d006bed0f9fbd6d2a65dc5da36817796 Mon Sep 17 00:00:00 2001 From: Julian Gruber Date: Wed, 21 Oct 2015 10:14:31 +0200 Subject: [PATCH] add .reset() --- README.md | 3 +++ index.js | 4 ++++ test/reset.js | 14 ++++++++++++++ 3 files changed, 21 insertions(+) create mode 100644 test/reset.js diff --git a/README.md b/README.md index c9c8b01..e350bd0 100644 --- a/README.md +++ b/README.md @@ -52,6 +52,9 @@ re.disconnect(); // ...or prevent reconnecting re.reconnect = false; + +// reset the internal backoff timer +re.reset(); ``` ## Available implementations diff --git a/index.js b/index.js index 5f35327..d0fa406 100644 --- a/index.js +++ b/index.js @@ -117,6 +117,10 @@ function (createConnection) { return emitter } + emitter.reset = function () { + backoffMethod.reset() + } + return emitter } diff --git a/test/reset.js b/test/reset.js new file mode 100644 index 0000000..7f2b93f --- /dev/null +++ b/test/reset.js @@ -0,0 +1,14 @@ + +var inject = require('..') +var test = require('tape') +var Stream = require('stream') + +var reconnect = inject(function () { + return new Stream +}) + +test('reset', function (t) { + // TODO real test + reconnect().reset() + t.end() +})