File tree Expand file tree Collapse file tree 1 file changed +10
-7
lines changed
example/web-next-transformstream/app Expand file tree Collapse file tree 1 file changed +10
-7
lines changed Original file line number Diff line number Diff line change @@ -65,17 +65,20 @@ const brotliDecompressTransformerBuilder: (
6565 stream : new brotliWasm . DecompressStream ( ) ,
6666 start ( ) { } ,
6767 transform ( chunk , controller ) {
68+ let resultCode
69+ let inputOffset = 0
6870 do {
69- const inputOffset = this . stream . last_input_offset ( )
7071 const input = chunk . slice ( inputOffset )
71- const output = this . stream . decompress ( input , this . outputSize )
72- controller . enqueue ( output )
73- } while ( this . stream . result ( ) === brotliWasm . BrotliStreamResult . NeedsMoreOutput )
72+ const result = this . stream . decompress ( input , this . outputSize )
73+ controller . enqueue ( result . buf )
74+ resultCode = result . code
75+ inputOffset += result . input_offset
76+ } while ( resultCode === brotliWasm . BrotliStreamResultCode . NeedsMoreOutput )
7477 if (
75- this . stream . result ( ) !== brotliWasm . BrotliStreamResult . NeedsMoreInput &&
76- this . stream . result ( ) !== brotliWasm . BrotliStreamResult . ResultSuccess
78+ resultCode !== brotliWasm . BrotliStreamResultCode . NeedsMoreInput &&
79+ resultCode !== brotliWasm . BrotliStreamResultCode . ResultSuccess
7780 ) {
78- controller . error ( `Brotli decompression failed when transforming with error code ${ this . stream . result ( ) } ` )
81+ controller . error ( `Brotli decompression failed with code ${ resultCode } ` )
7982 }
8083 } ,
8184 // Brotli decompression does not need flushing
You can’t perform that action at this time.
0 commit comments