Skip to content

Commit b6461b2

Browse files
committed
fix(flagd): Add thread interruption
Signed-off-by: Guido Breitenhuber <[email protected]>
1 parent 564a735 commit b6461b2

File tree

1 file changed

+1
-0
lines changed
  • providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync

1 file changed

+1
-0
lines changed

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,6 +192,7 @@ private void syncFlags(SyncStreamObserver streamObserver) {
192192
} catch (InterruptedException e) {
193193
log.warn("Sync stream interrupted, will restart", e);
194194
streamObserver.context.cancel(e);
195+
Thread.currentThread().interrupt();
195196
}
196197
}
197198
}

0 commit comments

Comments
 (0)