yetangitu/ya-webadb
1
0
Fork 0
mirror of https://github.com/yume-chan/ya-webadb.git synced 2025-10-03 09:49:24 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(stream): support async handler in InspectStream

Browse source
This commit is contained in:
Simon Chan 2025-08-28 16:36:24 +08:00
parent 3b71612b31
commit ae42638b8b
No known key found for this signature in database
GPG key ID: A8B69F750B9BCEDD
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
libraries/stream-extra/src/inspect.ts
View file

@ -1,13 +1,14 @@
import type { MaybePromiseLike } from "@yume-chan/async";
import { TransformStream } from "./stream.js"; import { TransformStream } from "./stream.js";
export class InspectStream<T> extends TransformStream<T, T> { export class InspectStream<T> extends TransformStream<T, T> {
constructor( constructor(
write: (value: T) => void, write: (value: T) => MaybePromiseLike<undefined>,
extras?: { close: () => void; cancel: () => void }, extras?: { close: () => void; cancel: () => void },
) { ) {
super({ super({
transform(chunk, controller) { async transform(chunk, controller) {
write(chunk); await write(chunk);
controller.enqueue(chunk); controller.enqueue(chunk);
}, },
flush() { flush() {