// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using Microsoft.AspNetCore.Hosting.Server;
using Microsoft.AspNetCore.Hosting.Server.Abstractions;
using Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Infrastructure;
 
namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Http3;
 
internal sealed class Http3Stream<TContext> : Http3Stream, IHostContextContainer<TContext> where TContext : notnull
{
    private readonly IHttpApplication<TContext> _application;
 
    public Http3Stream(IHttpApplication<TContext> application, Http3StreamContext context)
    {
        Initialize(context);
        _application = application;
    }
 
    public override void Execute()
    {
        KestrelEventSource.Log.RequestQueuedStop(this, AspNetCore.Http.HttpProtocol.Http3);
        ServiceContext.Metrics.RequestQueuedStop(MetricsContext, KestrelMetrics.Http3);
 
        if (_requestHeaderParsingState == RequestHeaderParsingState.Ready)
        {
            _ = ProcessRequestAsync(_application);
        }
        else
        {
            _ = ProcessRequestsAsync(_application);
        }
    }
 
    // Pooled Host context
    TContext? IHostContextContainer<TContext>.HostContext { get; set; }
}