@@ -139,14 +139,13 @@ ExecuteQuery(query, schema, variableValues, initialValue):
139
139
- If {defers} is an empty map and {streams} is an empty list:
140
140
- Return an unordered map containing {data} and {errors}.
141
141
- Otherwise:
142
- - Let {responseStream} be a new event stream.
143
- - Call {IncrementalEventStream(responseStream, data, errors, defers, streams,
144
- variableValues)} asynchronously.
145
- - Return {responseStream}.
142
+ - Return {IncrementalEventStream(data, errors, defers, streams,
143
+ variableValues)}.
146
144
147
- IncrementalEventStream(responseStream, data, errors, initialDefers,
148
- initialStreams, variableValues):
145
+ IncrementalEventStream(data, errors, initialDefers, initialStreams ,
146
+ variableValues):
149
147
148
+ - Return a new event stream {responseStream} which yields events as follows:
150
149
- Let {nextId} be {0}.
151
150
- Let {remainingDefers} be an empty set.
152
151
- Let {remainingStreams} be an empty set.
@@ -171,7 +170,7 @@ initialStreams, variableValues):
171
170
- Add {pendingStream} to {remainingStreams}.
172
171
- Let {initialResponse} be an unordered map containing {data}, {errors},
173
172
{pending}, and the value {true} for key {hasNext}.
174
- - Yield to {responseStream} the value {initialResponse}.
173
+ - Yield an event containing {initialResponse}.
175
174
- Let {incremental} be an empty list.
176
175
- Let {errors} be an empty list.
177
176
- Let {pending} be an empty list.
@@ -188,7 +187,7 @@ initialStreams, variableValues):
188
187
- Add {pending} to {incrementalPayload}.
189
188
- If {completed} is not empty:
190
189
- Add {completed} to {incrementalPayload}.
191
- - Yield to {responseStream} the value {incrementalPayload}.
190
+ - Yield an event containing {incrementalPayload}.
192
191
- Reset {incremental} to an empty list.
193
192
- Reset {errors} to an empty list.
194
193
- Reset {pending} to an empty list.
0 commit comments