From d36099a3386d571e4f034ee3c0b658564f4a61e9 Mon Sep 17 00:00:00 2001 From: Benjie Gillam Date: Thu, 21 Nov 2024 14:49:12 +0000 Subject: [PATCH] Handle errors raised by sourceStream --- spec/Section 6 -- Execution.md | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/spec/Section 6 -- Execution.md b/spec/Section 6 -- Execution.md index 8efd401a4..9d1f664f3 100644 --- a/spec/Section 6 -- Execution.md +++ b/spec/Section 6 -- Execution.md @@ -297,7 +297,12 @@ MapSourceToResponseEvent(sourceStream, subscription, schema, variableValues): - Let {response} be the result of running {ExecuteSubscriptionEvent(subscription, schema, variableValues, event)}. - Yield an event containing {response}. - - When {sourceStream} completes: complete {responseStream}. + - When {sourceStream} completes: + - If {sourceStream} completed with an {error}: + - Let {errors} be a list containing {error}. + - Let {response} be an unordered map containing {errors}. + - Yield an event containing {response}. + - Complete {responseStream}. ExecuteSubscriptionEvent(subscription, schema, variableValues, initialValue):