fixup: gemini suggestion

Author: aepfli

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

@@ -69,11 +69,7 @@ public SyncStreamQueueSource(final FlagdOptions options, Consumer<FlagdProviderE
                 FlagSyncServiceGrpc.newStub(channelConnector.getChannel()).withWaitForReady();
         metadataStub = FlagSyncServiceGrpc.newBlockingStub(channelConnector.getChannel())
                 .withWaitForReady();
-        scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
-            Thread t = new Thread(r, "flagd-sync-retry-scheduler");
-            t.setDaemon(true);
-            return t;
-        });
+        scheduler = createScheduler();
     }
 
     // internal use only
@@ -91,13 +87,17 @@ protected SyncStreamQueueSource(
         flagSyncStub = stubMock;
         syncMetadataDisabled = options.isSyncMetadataDisabled();
         metadataStub = blockingStubMock;
-        scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
-            Thread t = new Thread(r, "flagd-sync-retry-scheduler");
-            t.setDaemon(true);
-            return t;
-        });
+        scheduler = createScheduler();
     }
 
+    private static ScheduledExecutorService createScheduler() {  
+        return Executors.newSingleThreadScheduledExecutor(r -> {  
+            Thread t = new Thread(r, "flagd-sync-retry-scheduler");  
+            t.setDaemon(true);  
+            return t;  
+        });  
+    }  
+
     /** Initialize sync stream connector. */
     public void init() throws Exception {
         channelConnector.initialize();
@@ -151,6 +151,10 @@ private void observeSyncStream() {
             SyncStreamObserver observer = new SyncStreamObserver(outgoingQueue, shouldThrottle);
             try {
                 observer.metadata = getMetadata();
+            } catch (InterruptedException e) {  
+                Thread.currentThread().interrupt();  
+                log.debug("Metadata request interrupted, exiting stream loop.", e);  
+                break;  
             } catch (Exception metaEx) {
                 // retry if getMetadata fails
                 String message = metaEx.getMessage();
@@ -162,6 +166,10 @@ private void observeSyncStream() {
 
             try {
                 syncFlags(observer);
+            } catch (InterruptedException e) {  
+                Thread.currentThread().interrupt();  
+                log.debug("Metadata request interrupted, exiting stream loop.", e);  
+                break;  
             } catch (Exception ex) {
                 log.error("Unexpected sync stream exception, will restart.", ex);
                 enqueueError(String.format("Error in syncStream: %s", ex.getMessage()));
@@ -178,7 +186,7 @@ private void observeSyncStream() {
      */
     private void scheduleRetry() {
         if (shutdown.get()) {
-            log.info("Shutdown invoked, exiting event stream listener");
+            log.debug("Shutdown in progress, not scheduling retry.");
             return;
         }
         try {