(chunk, controller)
| 53 | return source.pipeThrough( |
| 54 | new TransformStream<Uint8Array, RuntimeFrame>({ |
| 55 | transform(chunk, controller) { |
| 56 | buffer += decoder.decode(chunk, { stream: true }); |
| 57 | drain(controller, false); |
| 58 | }, |
| 59 | flush(controller) { |
| 60 | buffer += decoder.decode(); |
| 61 | drain(controller, true); |