From c7bcaac3102228c8ca574454786be7bdabbb0fc1 Mon Sep 17 00:00:00 2001
From: Chris Eager <chris@signal.org>
Date: Fri, 14 Aug 2026 08:54:57 -0400
Subject: [PATCH] Check outstanding demand on internal trigger in FoundationDb
 publisher

---
 .../storage/foundationdb/FoundationDbMessagePublisher.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
index e361a6882..b4742c08d 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/foundationdb/FoundationDbMessagePublisher.java
@@ -236,7 +236,7 @@ class FoundationDbMessagePublisher {
             emitMessages();
           }
           case INTERNAL_TRIGGER -> {
-            if (emitter.requestedFromDownstream() > 0) {
+            if (getOutstandingDemand() > 0) {
               setState(State.FETCHING_MESSAGES, event);
               emitMessages();
             }