@orpc/server-standard-fetch
Advanced tools
Comparing version 0.2.0 to 0.3.0
@@ -10,5 +10,4 @@ // src/body.ts | ||
EventSourceUnknownErrorEvent, | ||
getEventSourceRetry, | ||
getTrackId, | ||
isProxyable, | ||
getEventSourceMeta, | ||
isEventSourceMetaContainer, | ||
parseEmptyableJSON, | ||
@@ -30,3 +29,3 @@ setEventSourceMeta | ||
let message = parseEmptyableJSON(value.data); | ||
if (isProxyable(message)) { | ||
if (isEventSourceMetaContainer(message)) { | ||
message = setEventSourceMeta(message, value); | ||
@@ -46,3 +45,3 @@ } | ||
let done2 = parseEmptyableJSON(value.data); | ||
if (isProxyable(done2)) { | ||
if (isEventSourceMetaContainer(done2)) { | ||
done2 = setEventSourceMeta(done2, value); | ||
@@ -74,5 +73,4 @@ } | ||
controller.enqueue(encodeEventSource({ | ||
...getEventSourceMeta(value.value), | ||
event: value.done ? "done" : "message", | ||
retry: getEventSourceRetry(value.value), | ||
id: getTrackId(value.value), | ||
data: JSON.stringify(value.value) | ||
@@ -85,5 +83,4 @@ })); | ||
controller.enqueue(encodeEventSource({ | ||
...getEventSourceMeta(err), | ||
event: "error", | ||
retry: getEventSourceRetry(err), | ||
id: getTrackId(err), | ||
data: err instanceof EventSourceErrorEvent ? JSON.stringify(err.data) : void 0 | ||
@@ -90,0 +87,0 @@ })); |
{ | ||
"name": "@orpc/server-standard-fetch", | ||
"type": "module", | ||
"version": "0.2.0", | ||
"version": "0.3.0", | ||
"license": "MIT", | ||
@@ -31,3 +31,3 @@ "homepage": "https://unnoq.com", | ||
"dependencies": { | ||
"@orpc/server-standard": "0.2.0" | ||
"@orpc/server-standard": "0.3.0" | ||
}, | ||
@@ -34,0 +34,0 @@ "devDependencies": { |
10628
252
+ Added@orpc/server-standard@0.3.0(transitive)
- Removed@orpc/server-standard@0.2.0(transitive)
Updated@orpc/server-standard@0.3.0