Skip to content

Commit a7f01cb

Browse files
committed
fix merge error re toy-server / latency
1 parent f8495d8 commit a7f01cb

1 file changed

Lines changed: 3 additions & 6 deletions

File tree

toys/StackExchange.Redis.Server/RespServer.cs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -469,8 +469,7 @@ static async ValueTask<bool> AwaitedExec(
469469
RespServer server,
470470
ValueTask pause,
471471
RedisClient client,
472-
RawResult requestBuffer,
473-
PipeWriter output)
472+
RawResult requestBuffer)
474473
{
475474
await pause.ConfigureAwait(false);
476475
TypedRedisValue response;
@@ -480,15 +479,13 @@ static async ValueTask<bool> AwaitedExec(
480479
server._arena.Reset();
481480
client.ResetAfterRequest();
482481
}
483-
484-
await WriteResponseAsync(client, output, response, client.Protocol).ConfigureAwait(false);
485-
response.Recycle();
482+
await client.AddOutboundAsync(response);
486483
return true;
487484
}
488485
if (!buffer.IsEmpty && TryParseRequest(_arena, ref buffer, out var requestBuffer))
489486
{
490487
var pause = ClientPauseAsync(client);
491-
if (!pause.IsCompletedSuccessfully) return AwaitedExec(this, pause, client, requestBuffer, output);
488+
if (!pause.IsCompletedSuccessfully) return AwaitedExec(this, pause, client, requestBuffer);
492489
TypedRedisValue response;
493490
var request = new RedisRequest(requestBuffer).WithClient(client);
494491
try { response = Execute(client, request); }

0 commit comments

Comments
 (0)