(client, pattern)
| 9 | const {EventEmitter: Emitter} = require('events'); |
| 10 | |
| 11 | function delKeys(client, pattern) { |
| 12 | const promise = helpers.deferred(), |
| 13 | done = promise.defer(); |
| 14 | client.keys(pattern, (err, keys) => { |
| 15 | if (err) return done(err); |
| 16 | if (keys.length) { |
| 17 | client.del(keys, done); |
| 18 | } else { |
| 19 | done(); |
| 20 | } |
| 21 | }); |
| 22 | return promise; |
| 23 | } |
| 24 | |
| 25 | // A promise-based barrier. |
| 26 | function reef(n = 1) { |