Using Capacitor Filesystem in a WriteStream

Hi, I am trying to pipe a writable stream to Filesystem.writeFile() like one would use the pipe(fs.createwritestream(url).

this.httpService.downloadFile()

        .pipe(

          toWritableStream(stream),

          map(async chunk => {

            // Convert to base64

            let base64Data = await this.b64FromStream(chunk);

            // append to file

            await Filesystem.appendFile({
              path: url,
              data: data,
              directory: Directory.Data,
            })
      }),

    )

    .subscribe();

Is there a better way to do this? It only seems to write the first chunk and then closes the write function.

Thanks!