I am working on a service that access XML files from FTP server. I am using basic-ftp for accessing ftp server. I am using downloadTo function

I have to download a file into writeable stream from FTP SERVER and then pipe this data to a function that accepts readable stream and parse the streamed XML data to json and insert into database.

I am unable to connect writeable stream into readable stream.

How can I achieve it? or is it even correct approach? Any suggestions.

I tried to create a writable stream and use pipe but that is not possible I guess.