INNER CODE UNIT · TypeScript

output

yume-chan/ya-webadb · libraries/adb-compression-zstd/src/index.ts:98

                    const output = await cleanupOnError(worker, () =>
                        rawStream.push(chunk),
                    );
                    if (output.length) {
                        controller.enqueue(output);
                    }
                },
                async flush(controller) {
                    const output = await cleanupOnError(worker, () =>
                        rawStream.finish(),
                    );
                    controller.enqueue(output);
                    worker?.terminate();
                },
                cancel() {
                    worker?.terminate();
                },
            });

View source record →