refactor: createAddStream

Author: ronag

lib/solr.ts

@@ -15,6 +15,8 @@ import {
 } from './types';
 import { Duplex } from 'stream';
 import { request } from 'undici';
+import undici from 'undici';
+import stream from 'stream';
 
 const oldRequest = require('request');
 const format = require('./utils/format');
@@ -300,10 +302,13 @@ export class Client {
       method: 'POST',
       headers: headers,
     };
-    const jsonStreamStringify = JSONStream.stringify();
-    const postRequest = oldRequest(optionsRequest);
-    jsonStreamStringify.pipe(postRequest);
-    return duplexer(jsonStreamStringify, postRequest);
+    return stream.compose(
+      JSONStream.stringify(),
+      undici.pipeline(optionsRequest, ({ statusCode, headers, body }) => {
+        // TODO:
+        return body
+      })
+    )
   }
 
   /**