// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
using System;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Internal;
using Microsoft.AspNetCore.InternalTesting;
using Xunit;
 
namespace Microsoft.AspNetCore.SignalR.Client.Tests;
 
public class TimerAwaitableTests
{
    [Fact]
    public async Task FinalizerRunsIfTimerAwaitableReferencesObject()
    {
        var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
        UseTimerAwaitableAndUnref(tcs);
 
        GC.Collect();
        GC.WaitForPendingFinalizers();
 
        // Make sure the finalizer runs
        await tcs.Task.DefaultTimeout();
    }
 
    [MethodImpl(MethodImplOptions.NoInlining)]
    private void UseTimerAwaitableAndUnref(TaskCompletionSource tcs)
    {
        _ = new ObjectWithTimerAwaitable(tcs).Start();
    }
}
 
// This object holds onto a TimerAwaitable referencing the callback (the async continuation is the callback)
// it also has a finalizer that triggers a tcs so callers can be notified when this object is being cleaned up.
public class ObjectWithTimerAwaitable
{
    private readonly TimerAwaitable _timer;
    private readonly TaskCompletionSource _tcs;
 
    public ObjectWithTimerAwaitable(TaskCompletionSource tcs)
    {
        _tcs = tcs;
        _timer = new TimerAwaitable(TimeSpan.FromSeconds(30), TimeSpan.FromSeconds(1));
        _timer.Start();
    }
 
    public async Task Start()
    {
        using (_timer)
        {
            while (await _timer)
            {
            }
        }
    }
 
    ~ObjectWithTimerAwaitable()
    {
        _tcs.TrySetResult();
    }
}