mapSourceToResponseEvent method

Stream<Map<String, dynamic>> mapSourceToResponseEvent(
  1. Stream sourceStream,
  2. OperationDefinitionContext subscription,
  3. GraphQLSchema schema,
  4. DocumentContext document,
  5. dynamic initialValue,
  6. Map<String, dynamic> variableValues,
  7. 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);
  }
}