subscribe method
Future<Stream<Map<String, dynamic>>>
subscribe(
- DocumentContext document,
- OperationDefinitionContext subscription,
- GraphQLSchema schema,
- Map<String, dynamic> variableValues,
- Map<String, dynamic> globalVariables,
- 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);
}