Commit 42b5a860 authored by Marc Gravell's avatar Marc Gravell

missing some ForAwait

parent 21704849
......@@ -913,7 +913,7 @@ private async ValueTask<WriteResult> WriteMessageTakingWriteLockAsync_Awaited(Va
{
try
{
using (var token = await pending)
using (var token = await pending.ForAwait())
{
if (!token.Success) return TimedOutBeforeWrite(message);
......@@ -921,7 +921,7 @@ private async ValueTask<WriteResult> WriteMessageTakingWriteLockAsync_Awaited(Va
if (result == WriteResult.Success)
{
result = await physical.FlushAsync(false);
result = await physical.FlushAsync(false).ForAwait();
}
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