teeny-request-npm-10.1.0.patch 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. diff --git a/build/src/index.js b/build/src/index.js
  2. index a101736..a87f6b9 100644
  3. --- a/build/src/index.js
  4. +++ b/build/src/index.js
  5. @@ -130,6 +130,9 @@ function createMultipartStream(boundary, multipart) {
  6. }
  7. else {
  8. part.body.pipe(stream, { end: false });
  9. + part.body.on('error', (err) => {
  10. + stream.destroy(err);
  11. + });
  12. part.body.on('end', () => {
  13. stream.write('\r\n');
  14. stream.write(finale);
  15. @@ -184,25 +187,25 @@ function teenyRequest(reqOpts, callback) {
  16. // Stream mode
  17. const requestStream = streamEvents(new stream_1.PassThrough());
  18. // eslint-disable-next-line @typescript-eslint/no-explicit-any
  19. - let responseStream;
  20. - requestStream.once('reading', () => {
  21. - if (responseStream) {
  22. - (0, stream_1.pipeline)(responseStream, requestStream, () => { });
  23. - }
  24. - else {
  25. - requestStream.once('response', () => {
  26. - (0, stream_1.pipeline)(responseStream, requestStream, () => { });
  27. - });
  28. - }
  29. - });
  30. + // let responseStream;
  31. + // requestStream.once('reading', () => {
  32. + // if (responseStream) {
  33. + // (0, stream_1.pipeline)(responseStream, requestStream, () => { });
  34. + // }
  35. + // else {
  36. + // requestStream.once('response', () => {
  37. + // (0, stream_1.pipeline)(responseStream, requestStream, () => { });
  38. + // });
  39. + // }
  40. + // });
  41. options.compress = false;
  42. teenyRequest.stats.requestStarting();
  43. - fetch(uri, options).then(res => {
  44. + (0, node_fetch_1.default)(uri, options).then(res => {
  45. - teenyRequest.stats.requestFinished();
  46. - responseStream = res.body;
  47. - responseStream.on('error', (err) => {
  48. - requestStream.emit('error', err);
  49. - });
  50. + teenyRequest.stats.requestFinished(); (0, stream_1.pipeline)(res.body, requestStream, () => {});
  51. + // responseStream = res.body;
  52. + // responseStream.on('error', (err) => {
  53. + // requestStream.emit('error', err);
  54. + // });
  55. const response = fetchToRequestResponse(options, res);
  56. requestStream.emit('response', response);
  57. }, err => {