Skip to content

Commit bf779f3

Browse files
Fix number of accounts processed counter
1 parent 4d81124 commit bf779f3

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

service/src/main/java/org/whispersystems/textsecuregcm/workers/EncryptDeviceCreationTimestampCommand.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,9 +78,10 @@ protected void crawlAccounts(final Flux<Account> accounts) {
7878
log.warn("Failed to encrypt creation timestamp on device {}, account {}", device.getId(), account.getUuid(), throwable);
7979
return Mono.empty();
8080
});
81-
}, MAX_CONCURRENCY),
81+
}, MAX_CONCURRENCY)
82+
.then()
83+
.doOnSuccess(_ -> processedAccountCounter.increment()),
8284
MAX_CONCURRENCY)
83-
.doOnComplete(processedAccountCounter::increment)
8485
.then()
8586
.block();
8687
}

0 commit comments

Comments
 (0)