@@ -244,7 +244,7 @@ import { pipeline } from 'node:stream';
244244const request = http .get ({ host: ' example.com' ,
245245 path: ' /' ,
246246 port: 80 ,
247- headers: { ' Accept-Encoding' : ' br,gzip,deflate' } });
247+ headers: { ' Accept-Encoding' : ' br,gzip,deflate,zstd ' } });
248248request .on (' response' , (response ) => {
249249 const output = fs .createWriteStream (' example.com_index.html' );
250250
@@ -266,6 +266,9 @@ request.on('response', (response) => {
266266 case ' deflate' :
267267 pipeline (response, zlib .createInflate (), output, onError);
268268 break ;
269+ case ' zstd' :
270+ pipeline (response, zlib .createZstdDecompress (), output, onError);
271+ break ;
269272 default :
270273 pipeline (response, output, onError);
271274 break ;
@@ -353,6 +356,9 @@ http.createServer((request, response) => {
353356 } else if (/ \b br\b / .test (acceptEncoding)) {
354357 response .writeHead (200 , { ' Content-Encoding' : ' br' });
355358 pipeline (raw, zlib .createBrotliCompress (), response, onError);
359+ } else if (/ \b zstd\b / .test (acceptEncoding)) {
360+ response .writeHead (200 , { ' Content-Encoding' : ' zstd' });
361+ pipeline (raw, zlib .createZstdCompress (), response, onError);
356362 } else {
357363 response .writeHead (200 , {});
358364 pipeline (raw, response, onError);
0 commit comments