diff --git a/ImapManager.js b/ImapManager.js index dfe0562..0f2c718 100644 --- a/ImapManager.js +++ b/ImapManager.js @@ -173,7 +173,7 @@ ImapManager.prototype.onMessage = function*(fetchState, msg, seqnum, processor) fetchState.pending.push([ msgrow, attrs ]); fetchState.parsed++; - if (!fetchState.paused && fetchState.parsed >= 100) + if (!fetchState.paused && fetchState.parsed >= 100 && !fetchState.nopause) { // ГОРШОЧЕК, НЕ ВАРИ!!! И так уже кучу сообщений прочитал из сокета, хорош! fetchState.srv._parser._ignoreReadable = true; diff --git a/Syncer.js b/Syncer.js index 5bbb514..127674c 100644 --- a/Syncer.js +++ b/Syncer.js @@ -245,7 +245,7 @@ Syncer.prototype.fullResync = function*(srv, boxId, maxUid, missing, total) yield* this.imap.runFetch( srv, '1:'+maxUid, {}, (messages, state) => this.queueFlags(messages, boxId, state), - { flags: flags, updateFlags: updateFlags, missing: missing||[], total: total } + { flags: flags, updateFlags: updateFlags, missing: missing||[], total: total, nopause: true } ); process.stderr.write('\n'); this.events.emit('sync', { state: 'finish-box' });