mapSourceToResponseEvent method
Stream<Map<String, dynamic>>
mapSourceToResponseEvent(
- Stream sourceStream,
- OperationDefinitionContext subscription,
- GraphQLSchema schema,
- DocumentContext document,
- dynamic initialValue,
- Map<String, dynamic> variableValues,
- Map<String, dynamic> globalVariables,
)
Implementation
Stream<Map<String, dynamic>> mapSourceToResponseEvent(
Stream sourceStream,
OperationDefinitionContext subscription,
GraphQLSchema schema,
DocumentContext document,
initialValue,
Map<String, dynamic> variableValues,
Map<String, dynamic> globalVariables,
) async* {
await for (var event in sourceStream) {
yield await executeSubscriptionEvent(document, subscription, schema,
event, variableValues, globalVariables);
}
}