subscribe method

Future<Stream<Map<String, dynamic>>> subscribe(
  1. DocumentContext document,
  2. OperationDefinitionContext subscription,
  3. GraphQLSchema schema,
  4. Map<String, dynamic> variableValues,
  5. Map<String, dynamic> globalVariables,
  6. dynamic initialValue,
)

Implementation

Future<Stream<Map<String, dynamic>>> subscribe(
    DocumentContext document,
    OperationDefinitionContext subscription,
    GraphQLSchema schema,
    Map<String, dynamic> variableValues,
    Map<String, dynamic> globalVariables,
    initialValue) async {
  var sourceStream = await createSourceEventStream(
      document, subscription, schema, variableValues, initialValue);
  return mapSourceToResponseEvent(sourceStream, subscription, schema,
      document, initialValue, variableValues, globalVariables);
}