Closed timkuijsten closed 9 years ago
since the consumer can resume the database stream and handleItem relies on the input being paused, a race condition exists.
refactor the code to use async.queue to ensure items are being processed serially.
since the consumer can resume the database stream and handleItem relies on the input being paused, a race condition exists.
refactor the code to use async.queue to ensure items are being processed serially.