fix: udpated the breaking code for graphql-subscriptions

instana · Nov 13, 2024 · 17f0dbf · 17f0dbf
1 parent 8efb3a0
commit 17f0dbf
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/packages/collector/test/tracing/protocols/graphql/schema.js b/packages/collector/test/tracing/protocols/graphql/schema.js
@@ -202,7 +202,13 @@ module.exports = function exportSchema() {
           },
           subscribe: (__, { id }) => {
             pinoLogger.warn(`subscribe: ${id}`);
-            return pubsub.asyncIterator('characterUpdated');
+
+            // for graphql-subscriptions/releases version 3, asyncIterator is replaced with asyncIterableIterator
+            if (pubsub?.asyncIterableIterator) {
+              return pubsub.asyncIterableIterator('characterUpdated');
+            } else {
+              return pubsub.asyncIterator('characterUpdated');
+            }
           }
         }
       }