How to use the fs-capacitor.WriteStream function in fs-capacitor
To help you get started, we’ve selected a few fs-capacitor examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
qmit-pro / moleculer-api / src / schema / plugin / protocol / rest / handler / multipart.ts View on Github 
parser.on("file", (fieldname, stream, filename, encoding, mimetype) => {
if (exitError) {
this.wasteStream(stream);
return;
}
currentStream = stream;
stream.on("end", () => {
currentStream = undefined;
});
// create buffer stream
const capacitor = new WriteStream();
capacitor.on("error", () => {
stream.unpipe();
stream.resume();
});
stream.on("error", error => {
stream.unpipe();
capacitor.destroy(error);
});
stream.on("limit", () => {
stream.unpipe();
capacitor.destroy(new Error(`file ${filename} exceeds the ${this.props.maxFileSize} byte size limit`)); // TODO: normalize error
});fs-capacitor
Filesystem-buffered, passthrough stream that buffers indefinitely rather than propagate backpressure from downstream consumers.
