Add await async
This commit is contained in:
parent
5345953629
commit
c7d2ec9899
@ -369,7 +369,7 @@ namespace Server.MessagePack
|
|||||||
tmp.SetAsInteger(value);
|
tmp.SetAsInteger(value);
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<bool> LoadFileAsBytes(string fileName)
|
public async Task<bool> LoadFileAsBytes(string fileName)
|
||||||
{
|
{
|
||||||
if (File.Exists(fileName))
|
if (File.Exists(fileName))
|
||||||
{
|
{
|
||||||
@ -377,6 +377,7 @@ namespace Server.MessagePack
|
|||||||
FileStream fs = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.Read);
|
FileStream fs = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.Read);
|
||||||
value = new byte[fs.Length];
|
value = new byte[fs.Length];
|
||||||
await fs.ReadAsync(value, 0, (int)fs.Length);
|
await fs.ReadAsync(value, 0, (int)fs.Length);
|
||||||
|
await fs.FlushAsync();
|
||||||
fs.Close();
|
fs.Close();
|
||||||
fs.Dispose();
|
fs.Dispose();
|
||||||
SetAsBytes(value);
|
SetAsBytes(value);
|
||||||
@ -389,12 +390,13 @@ namespace Server.MessagePack
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public bool SaveBytesToFile(string fileName)
|
public async Task<bool> SaveBytesToFile(string fileName)
|
||||||
{
|
{
|
||||||
if (this.innerValue != null)
|
if (this.innerValue != null)
|
||||||
{
|
{
|
||||||
FileStream fs = new FileStream(fileName, FileMode.Append);
|
FileStream fs = new FileStream(fileName, FileMode.Append);
|
||||||
fs.Write(((byte[])this.innerValue), 0, ((byte[])this.innerValue).Length);
|
await fs.WriteAsync(((byte[])this.innerValue), 0, ((byte[])this.innerValue).Length);
|
||||||
|
await fs.FlushAsync();
|
||||||
fs.Close();
|
fs.Close();
|
||||||
fs.Dispose();
|
fs.Dispose();
|
||||||
return true;
|
return true;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user