-void QtUiMessageProcessor::processMessages(QList<Message> &msgs) {
- foreach(Message msg, msgs) {
- checkForHighlight(msg);
- Client::messageModel()->insertMessage(msg);
+void QtUiMessageProcessor::processNextMessage() {
+ if(_currentBatch.isEmpty()) {
+ if(_processQueue.isEmpty()) {
+ _processTimer.stop();
+ _processing = false;
+ _msgsProcessed = _msgCount = 0;
+ updateProgress();
+ return;
+ }
+ _currentBatch = _processQueue.takeFirst();
+ }
+ Message msg = _currentBatch.takeFirst();
+ process(msg);
+ _msgsProcessed++;
+ updateProgress();
+}
+
+void QtUiMessageProcessor::updateProgress(bool start) {
+ if(start) {
+ _progressTimer.start();
+ emit progressUpdated(_msgsProcessed, _msgCount);
+ } else {
+ if(_msgCount == 0 || _progressTimer.elapsed() >= progressUpdateDelay) {
+ _progressTimer.restart();
+ emit progressUpdated(_msgsProcessed, _msgCount);
+ }