using System;
using System.Threading;
using System.Threading.Tasks;
using Example.Shared;
using mROA.Implementation.Attributes;

namespace Example.Backend
{
    [SharedObjectSingleton]
    public class LoadTestImp : ILoadTest
    {
        public static int N;
        public Task<int> Next(int last)
        {
            Console.WriteLine(++N);
            return Task.FromResult( last + 1);
        }

        public int Last(int next)
        {
            return next - 1;
        }

        public void C()
        {
            Environment.Exit(0);
        }

        public void A()
        {
            throw new NotImplementedException();
        }

        public async Task AsyncTest(CancellationToken token)
        {
            Console.WriteLine("Async Test");

            for (int i = 0; i < 10; i++)
            {
                if (token.IsCancellationRequested)
                {
                    Console.WriteLine("Waiting canceled");
                    return;
                }

                Console.WriteLine("Waiting...");
                await Task.Delay(1000);
            }


            Console.WriteLine("Waited until the end");
        }
    }
}