| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- diff --git a/build/src/index.js b/build/src/index.js
- index a101736..a87f6b9 100644
- --- a/build/src/index.js
- +++ b/build/src/index.js
- @@ -130,6 +130,9 @@ function createMultipartStream(boundary, multipart) {
- }
- else {
- part.body.pipe(stream, { end: false });
- + part.body.on('error', (err) => {
- + stream.destroy(err);
- + });
- part.body.on('end', () => {
- stream.write('\r\n');
- stream.write(finale);
- @@ -184,25 +187,25 @@ function teenyRequest(reqOpts, callback) {
- // Stream mode
- const requestStream = streamEvents(new stream_1.PassThrough());
- // eslint-disable-next-line @typescript-eslint/no-explicit-any
- - let responseStream;
- - requestStream.once('reading', () => {
- - if (responseStream) {
- - (0, stream_1.pipeline)(responseStream, requestStream, () => { });
- - }
- - else {
- - requestStream.once('response', () => {
- - (0, stream_1.pipeline)(responseStream, requestStream, () => { });
- - });
- - }
- - });
- + // let responseStream;
- + // requestStream.once('reading', () => {
- + // if (responseStream) {
- + // (0, stream_1.pipeline)(responseStream, requestStream, () => { });
- + // }
- + // else {
- + // requestStream.once('response', () => {
- + // (0, stream_1.pipeline)(responseStream, requestStream, () => { });
- + // });
- + // }
- + // });
- options.compress = false;
- teenyRequest.stats.requestStarting();
- - fetch(uri, options).then(res => {
- + (0, node_fetch_1.default)(uri, options).then(res => {
- - teenyRequest.stats.requestFinished();
- - responseStream = res.body;
- - responseStream.on('error', (err) => {
- - requestStream.emit('error', err);
- - });
- + teenyRequest.stats.requestFinished(); (0, stream_1.pipeline)(res.body, requestStream, () => {});
- + // responseStream = res.body;
- + // responseStream.on('error', (err) => {
- + // requestStream.emit('error', err);
- + // });
- const response = fetchToRequestResponse(options, res);
- requestStream.emit('response', response);
- }, err => {
|