@@ -306,12 +306,18 @@ MapSourceToResponseEvent(sourceStream, subscription, schema, variableValues):
306
306
sourceValue)}.
307
307
- If internal {error} was raised:
308
308
- Cancel {sourceStream}.
309
- - Perform {EmitErrorAndComplete(responseStream, error)}.
309
+ - Let {errors} be a list containing {error}.
310
+ - Let {response} be an unordered map containing {errors}.
311
+ - Emit {response} on {responseStream}.
312
+ - Complete {responseStream} normally.
310
313
- Otherwise emit {response} on {responseStream}.
311
314
- When {sourceStream} completes normally:
312
315
- Complete {responseStream} normally.
313
316
- When {sourceStream} completes with {error}:
314
- - Perform {EmitErrorAndComplete(responseStream, error)}.
317
+ - Let {errors} be a list containing {error}.
318
+ - Let {response} be an unordered map containing {errors}.
319
+ - Emit {response} on {responseStream}.
320
+ - Complete {responseStream} normally.
315
321
- When {responseStream} is cancelled:
316
322
- Cancel {sourceStream}.
317
323
- Complete {responseStream} normally.
@@ -337,13 +343,6 @@ ExecuteSubscriptionEvent(subscription, schema, variableValues, initialValue):
337
343
Note: The {ExecuteSubscriptionEvent()} algorithm is intentionally similar to
338
344
{ExecuteQuery()} since this is how each event result is produced.
339
345
340
- EmitErrorAndComplete(responseStream, error):
341
-
342
- - Let {errors} be a list containing {error}.
343
- - Let {response} be an unordered map containing {errors}.
344
- - Emit {response} on {responseStream}.
345
- - Complete {responseStream} normally.
346
-
347
346
#### Unsubscribe
348
347
349
348
Unsubscribe cancels the Response Stream when a client no longer wishes to
0 commit comments