We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5695588 commit 678ee45Copy full SHA for 678ee45
json-parse-stream.ts
@@ -25,7 +25,7 @@ export class JSONParseStream<T = any> extends TransformStream<string | Uint8Arra
25
26
if (match(expr, path)) {
27
controller.enqueue(value as any);
28
- } else if (expr.startsWith(path)) {
+ } else if (expr.startsWith(path + ';')) {
29
controller.terminate()
30
}
31
};
@@ -60,7 +60,7 @@ export class JSONParseNexus<T = any> extends TransformStream<string | Uint8Array
60
61
this.#queues.get(expr)!.enqueue(value)
62
} // no else if => can both be true
63
- if (expr.startsWith(path)) {
+ if (expr.startsWith(path + ';')) {
64
remove(this.#queues, expr)!.close()
65
66
0 commit comments