jpwilliams / remit / 492

87%

push

travis-ci

feat(endpoints/listeners): add the ability to pause/resume consumers (#73)

* 🚩(endpoints): add new pausing capabilities

Includes two new functions on endpoints - `pause` and `resume`.
`pause` take a single argument, `cold`, which manages whether or not to still handle any messages currently being processed.

To manage this functionality, a few promises are passed around (`this._starting`, `this._resuming`, `this._paused` and `this._cold`).
This is currently necessary to fight off multiple calls to the same functions and to correctly handle interrupting processing if a cold pause has been requested.

This will also need adding to listeners as well as docs and tests adding.

* 🚩(listeners): adding new pausing capabilities

* ✅(endpoints): adding some tests for pausing/resuming

* fix(responses): adjust pause/resume so identical promises are returned on repeated hits

* test(endpoints): add remaining endpoint tests for pausing/resuming

* (responders): resolve with `this` in pausing/resuming so we can carry on chaining

* test(endpoints): adjust tests to expect endpoint resolution from pause/resume

* test(endpoints): cleaning up logs (whoops)

* docs(api): add .pause() and .resume() docs for listeners and endpoints

* docs(responders): add `cold` parameter to `pause` function definitions

202 of 268 branches covered (75.37%)

482 of 560 relevant lines covered (86.07%)

20.8 hits per line