nagle.cs

const int maxBuffer = 1024;

while (true)
{
    var result = await application.Output.ReadAsync();
    var buffer = result.Buffer;

    // Check if we have enough to perform a write
    if (buffer.Length >= maxBuffer)
    {
        await WriteAsync(buffer);
    }
    else
    {
        while (buffer.Length < maxBuffer)
        {
            var length = buffer.Length;
            // If we're under, we want to start buffering, act like we consumed
            // nothing but looked at everything so we can wait for more data
            application.Output.AdvanceTo(buffer.Start, buffer.End);

            // Dispatch to the thread pool to inject some latency (this *could* be another queue)
            await Task.Yield();
            
            // TryRead should *always* return true since we know we have something to write
            var hasData = application.Output.TryRead(out result);
            buffer = result.Buffer;
            
            Debug.Assert(hasData, "We should have data buffered");
            
            if (buffer.Length == length)
            {
                // We didn't get more data so write what we have
                break;
            }
        }

        await WriteAsync(buffer);
    }

    application.Output.AdvanceTo(buffer.End);
}