update writeStream to async function
This commit is contained in:
parent
6773c07f2d
commit
e61b14c373
|
@ -22,11 +22,11 @@ export const checkExistsAndRename = async (
|
|||
}
|
||||
};
|
||||
|
||||
export const saveStreamToDisk = (
|
||||
export const saveStreamToDisk = async (
|
||||
filePath: string,
|
||||
fileStream: ReadableStream<any>
|
||||
fileStream: ReadableStream<Uint8Array>
|
||||
) => {
|
||||
writeStream(filePath, fileStream);
|
||||
await writeStream(filePath, fileStream);
|
||||
};
|
||||
|
||||
export const saveFileToDisk = async (path: string, fileData: any) => {
|
||||
|
|
|
@ -212,14 +212,14 @@ export const convertBrowserStreamToNode = (
|
|||
return rs;
|
||||
};
|
||||
|
||||
export function writeStream(
|
||||
export async function writeStream(
|
||||
filePath: string,
|
||||
fileStream: ReadableStream<Uint8Array>
|
||||
) {
|
||||
const writeable = fs.createWriteStream(filePath);
|
||||
const readable = convertBrowserStreamToNode(fileStream);
|
||||
readable.pipe(writeable);
|
||||
return new Promise((resolve, reject) => {
|
||||
await new Promise((resolve, reject) => {
|
||||
writeable.on('finish', resolve);
|
||||
writeable.on('error', reject);
|
||||
});
|
||||
|
|
Loading…
Reference in a new issue