Skip to content

Instantly share code, notes, and snippets.

@jakearchibald
Last active September 27, 2022 01:15
Show Gist options
  • Star 7 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
  • Save jakearchibald/c2052ef298459355963b8cfb79c71d1c to your computer and use it in GitHub Desktop.
Save jakearchibald/c2052ef298459355963b8cfb79c71d1c to your computer and use it in GitHub Desktop.
export default function parseJSON() {
return new TransformStream({
transform(chunk, controller) {
controller.enqueue(JSON.parse(chunk));
}
});
}
export default function splitStream(splitOn) {
let buffer = '';
return new TransformStream({
transform(chunk, controller) {
buffer += chunk;
const parts = buffer.split(splitOn);
parts.slice(0, -1).forEach(part => controller.enqueue(part));
buffer = parts[parts.length - 1];
},
flush(controller) {
if (buffer) controller.enqueue(buffer);
}
});
}
@jfbrennan
Copy link

return new TransformStream() <-- you're instantiating one of these https://streams.spec.whatwg.org/#ts-class? I can't find anything on the web about those... People write about streams, but I can't find any other examples of TransformStream or their current support.

Was reading this and came here to learn. Can you explain more?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment