Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-09-03 00:30:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

Check outstanding demand on internal trigger in FoundationDb publisher

Browse Source
This commit is contained in:
Chris Eager
2026-08-18 11:19:45 -04:00
committed by Chris Eager
parent 1366fbba8a
commit c7bcaac310
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
+1 -1
View File
@@ -236,7 +236,7 @@ class FoundationDbMessagePublisher {
emitMessages();
}
case INTERNAL_TRIGGER -> {
if (emitter.requestedFromDownstream() > 0) {
if (getOutstandingDemand() > 0) {
setState(State.FETCHING_MESSAGES, event);
emitMessages();
}