Commit 637ee0e5 authored by Marc Gravell's avatar Marc Gravell

missing some ForAwait

parent 4ebacd62
...@@ -913,7 +913,7 @@ private async ValueTask<WriteResult> WriteMessageTakingWriteLockAsync_Awaited(Va ...@@ -913,7 +913,7 @@ private async ValueTask<WriteResult> WriteMessageTakingWriteLockAsync_Awaited(Va
{ {
try try
{ {
using (var token = await pending) using (var token = await pending.ForAwait())
{ {
if (!token.Success) return TimedOutBeforeWrite(message); if (!token.Success) return TimedOutBeforeWrite(message);
...@@ -921,7 +921,7 @@ private async ValueTask<WriteResult> WriteMessageTakingWriteLockAsync_Awaited(Va ...@@ -921,7 +921,7 @@ private async ValueTask<WriteResult> WriteMessageTakingWriteLockAsync_Awaited(Va
if (result == WriteResult.Success) if (result == WriteResult.Success)
{ {
result = await physical.FlushAsync(false); result = await physical.FlushAsync(false).ForAwait();
} }
UnmarkActiveMessage(message); UnmarkActiveMessage(message);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment