123456789101112131415161718192021222324252627 |
- import {
- TransformStream,
- } from 'node:stream/web';
- import {transform} from './api/index.js';
- const parse = (opts) => {
- const api = transform(opts);
- return new TransformStream({
- async transform(chunk, controller) {
- api.parse(chunk, false, (record) => {
- controller.enqueue(record);
- }, () => {
- controller.close();
- });
- },
- async flush(controller){
- api.parse(undefined, true, (record) => {
- controller.enqueue(record);
- }, () => {
- controller.close();
- });
- }
- });
- };
- export {parse};
|