[rs, out].forEach((stream) =>
        stream.on('error', (err) => {
            store.onReadError.call(store, err, fileId, file);
            out.end();
        }),