Fix subscription

Co-authored-by: Shane Krueger <shane@acdmail.com>
graphql-dotnet · Jul 4, 2022 · 115a9b3 · 115a9b3
1 parent d7a26fb
commit 115a9b3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/src/GraphQL.Conventions/Adapters/GraphTypeAdapter.cs b/src/GraphQL.Conventions/Adapters/GraphTypeAdapter.cs
@@ -96,7 +96,7 @@ private FieldType DeriveField(GraphFieldInfo fieldInfo)
                     DefaultValue = fieldInfo.DefaultValue,
                     Type = GetType(fieldInfo.Type),
                     Arguments = new QueryArguments(fieldInfo.Arguments.Where(arg => !arg.IsInjected).Select(DeriveArgument)),
-                    Resolver = resolver,
+                    Resolver = streamResolver,
                     StreamResolver = streamResolver
                 };
             }

diff --git a/src/GraphQL.Conventions/Adapters/Resolvers/EventStreamResolver.cs b/src/GraphQL.Conventions/Adapters/Resolvers/EventStreamResolver.cs
@@ -4,7 +4,7 @@
 
 namespace GraphQL.Conventions.Adapters.Resolvers
 {
-    public class EventStreamResolver : ISourceStreamResolver
+    public class EventStreamResolver : ISourceStreamResolver, IFieldResolver
     {
         private readonly IFieldResolver _fieldResolver;
 
@@ -22,5 +22,10 @@ public async ValueTask<IObservable<object>> ResolveAsync(IResolveFieldContext co
             }
             return (IObservable<object>)result;
         }
+
+        ValueTask<object> IFieldResolver.ResolveAsync(IResolveFieldContext context)
+        {
+            return new(context.Source);
+        }
     }
 }