Skip to content

Commit e4760cb

Browse files
committed
feat(AtomicFileAdapter): Add support for fsync
1 parent 8e415e6 commit e4760cb

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/adapter/file/AtomicFileAdapter.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,11 @@ import {readFile, writeFile} from "atomically";
33

44
export class AtomicFileAdapter implements IFileAdapter<string> {
55
public readonly filename: string;
6+
private fsync: boolean;
67

7-
constructor(filename: string) {
8+
constructor(filename: string, fsync: boolean) {
89
this.filename = filename;
10+
this.fsync = fsync;
911
}
1012

1113
async readAsync(): Promise<string | null> {
@@ -23,7 +25,8 @@ export class AtomicFileAdapter implements IFileAdapter<string> {
2325

2426
writeAsync(data: string): Promise<void> {
2527
return writeFile(this.filename, data, {
26-
encoding: 'utf-8'
28+
encoding: 'utf-8',
29+
fsync: this.fsync
2730
})
2831
}
2932
}

0 commit comments

Comments
 (0)