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: (
65
65
stream : new brotliWasm . DecompressStream ( ) ,
66
66
start ( ) { } ,
67
67
transform ( chunk , controller ) {
68
+ let resultCode
69
+ let inputOffset = 0
68
70
do {
69
- const inputOffset = this . stream . last_input_offset ( )
70
71
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 )
74
77
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
77
80
) {
78
- controller . error ( `Brotli decompression failed when transforming with error code ${ this . stream . result ( ) } ` )
81
+ controller . error ( `Brotli decompression failed with code ${ resultCode } ` )
79
82
}
80
83
} ,
81
84
// Brotli decompression does not need flushing
You can’t perform that action at this time.
0 commit comments