44using System . Security . Claims ;
55using GraphQL . Resolvers ;
66using GraphQL . Server . Transports . Subscriptions . Abstractions ;
7- using GraphQL . Subscription ;
87using GraphQL . Types ;
98
109namespace GraphQL . Samples . Schemas . Chat
@@ -16,15 +15,15 @@ public class ChatSubscriptions : ObjectGraphType<object>
1615 public ChatSubscriptions ( IChat chat )
1716 {
1817 _chat = chat ;
19- AddField ( new EventStreamFieldType
18+ AddField ( new FieldType
2019 {
2120 Name = "messageAdded" ,
2221 Type = typeof ( MessageType ) ,
2322 Resolver = new FuncFieldResolver < Message > ( ResolveMessage ) ,
2423 Subscriber = new EventStreamResolver < Message > ( Subscribe )
2524 } ) ;
2625
27- AddField ( new EventStreamFieldType
26+ AddField ( new FieldType
2827 {
2928 Name = "messageAddedByUser" ,
3029 Arguments = new QueryArguments (
@@ -36,7 +35,7 @@ public ChatSubscriptions(IChat chat)
3635 } ) ;
3736 }
3837
39- private IObservable < Message > SubscribeById ( IResolveEventStreamContext context )
38+ private IObservable < Message > SubscribeById ( IResolveFieldContext context )
4039 {
4140 var messageContext = ( MessageHandlingContext ) context . UserContext ;
4241 var user = messageContext . Get < ClaimsPrincipal > ( "user" ) ;
@@ -58,7 +57,7 @@ private Message ResolveMessage(IResolveFieldContext context)
5857 return message ;
5958 }
6059
61- private IObservable < Message > Subscribe ( IResolveEventStreamContext context )
60+ private IObservable < Message > Subscribe ( IResolveFieldContext context )
6261 {
6362 var messageContext = ( MessageHandlingContext ) context . UserContext ;
6463 var user = messageContext . Get < ClaimsPrincipal > ( "user" ) ;
0 commit comments