()
| 112 | |
| 113 | const consumeResults = function (pq, cb) { |
| 114 | const cleanup = function () { |
| 115 | pq.removeListener('readable', onReadable) |
| 116 | pq.stopReader() |
| 117 | } |
| 118 | |
| 119 | const readError = function (message) { |
| 120 | cleanup() |
no outgoing calls
no test coverage detected