Commit367b067

authored

fix(wasm): sync file changes after write or truncate (#6)

1 parent54b9c90 commit367b067Copy full SHA for 367b067

File tree

+14

-3

lines changed

+14

-3

lines changed

Lines changed: 12 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -91,9 +91,18 @@ async fn get_file_handle(`
`91`	`91`	`.unchecked_into::<FileSystemSyncAccessHandle>();`
`92`	`92`
`93`	`93`	`if truncate{`
`94`		`- sync_access_handle`
`95`		`-.truncate_with_u32(0)`
`96`		`-.map_err(\|err\|OpfsError::from(err).into_io_err())?;`
	`94`	`+ sync_access_handle.truncate_with_u32(0).map_or_else(`
	`95`	`+ \|err\|{`
	`96`	`+ sync_access_handle.close();`
	`97`	`+Err(OpfsError::from(err).into_io_err())`
	`98`	`+},`
	`99`	`+ \|_\|{`
	`100`	`+ sync_access_handle.flush().map_err(\|err\|{`
	`101`	`+ sync_access_handle.close();`
	`102`	`+OpfsError::from(err).into_io_err()`
	`103`	`+})`
	`104`	`+},`
	`105`	`+)?;`
`97`	`106`	`}`
`98`	`107`	`Ok(sync_access_handle)`
`99`	`108`	`}`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -16,5 +16,7 @@ pub async fn write(path: impl AsRef<Path>, content: impl AsRef<[u8]>) -> io::Res`
`16`	`16`
`17`	`17`	`file.write_with_buf(content.as_ref())?;`
`18`	`18`
	`19`	`+ file.sync_data().await?;`
	`20`	`+`
`19`	`21`	`Ok(())`
`20`	`22`	`}`

Comments

(0)