816476018

Build Type

github

Committed by GitHub

Commit Message

Merge cc12d1f2c into 68c3dbcc7

Pull Request Pull Request #1086: Fix 966 command autoexecute

Run Details

2315 of 3702 branches covered (62.53%)

Branch coverage included in aggregate %.

12 of 20 new or added lines in 5 files covered. (60.0%)

16 existing lines in 8 files now uncovered.

6157 of 8058 relevant lines covered (76.41%)

47682.29 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/Zilon.Core/Zilon.Core/Client/Sector/GlobeLoopUpdater.cs

﻿using System;
using System.Threading;
using System.Threading.Tasks;

using JetBrains.Annotations;

namespace Zilon.Core.Client.Sector
{
    public sealed class GlobeLoopUpdater : IDisposable, IGlobeLoopUpdater
    {
        [NotNull] private readonly IAnimationBlockerService _animationBlockerService;

        [NotNull] private readonly IGlobeLoopContext _gameLoopContext;

        private CancellationTokenSource? _cancellationTokenSource;

        public GlobeLoopUpdater(
            IGlobeLoopContext gameLoopContext,
            IAnimationBlockerService animationBlockerService)
        {
            _gameLoopContext = gameLoopContext;
            _animationBlockerService = animationBlockerService;
        }

        public void Dispose()
        {
            if (_cancellationTokenSource != null)
            {
                _cancellationTokenSource.Dispose();
            }
        }

        private async Task StartGameLoopUpdateAsync(CancellationToken cancelToken)
        {
            while (_gameLoopContext.HasNextIteration)
            {
                cancelToken.ThrowIfCancellationRequested();

                try
                {
                    await _gameLoopContext.UpdateAsync(cancelToken);
                }
                catch (Exception exception)
                {
                    ErrorOccured?.Invoke(this, new ErrorOccuredEventArgs(exception));
                }

                var animationBlockerTask = _animationBlockerService.WaitBlockersAsync();
                var fuseDelayTask = Task.Delay(10_000, cancelToken);

                await Task.WhenAny(animationBlockerTask, fuseDelayTask).ConfigureAwait(false);
                _animationBlockerService.DropBlockers();
            }
        }

        public bool IsStarted { get; private set; }

        public event EventHandler<ErrorOccuredEventArgs>? ErrorOccured;

        public void Start()
        {
            _cancellationTokenSource = new CancellationTokenSource();

            var cancelToken = _cancellationTokenSource.Token;

            var updateTask = StartGameLoopUpdateAsync(cancelToken);

            updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnFaulted);
            updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnCanceled);
            updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnRanToCompletion);

            IsStarted = true;
        }

        public void Stop()
        {
            if (_cancellationTokenSource != null)
            {
                _cancellationTokenSource.Cancel();
            }
        }
    }
}

1	using System;
2	using System.Threading;
3	using System.Threading.Tasks;
4
5	using JetBrains.Annotations;
6
7	namespace Zilon.Core.Client.Sector
8	{
9	public sealed class GlobeLoopUpdater : IDisposable, IGlobeLoopUpdater
10	{
11	[NotNull] private readonly IAnimationBlockerService _animationBlockerService;
12
13	[NotNull] private readonly IGlobeLoopContext _gameLoopContext;
14
15	private CancellationTokenSource? _cancellationTokenSource;
16
17	public GlobeLoopUpdater(	×
18	IGlobeLoopContext gameLoopContext,	×
19	IAnimationBlockerService animationBlockerService)	×
20	{
NEW 21	_gameLoopContext = gameLoopContext;	×
NEW 22	_animationBlockerService = animationBlockerService;	×
UNCOV 23	}	×
24
25	public void Dispose()
26	{
27	if (_cancellationTokenSource != null)	×
28	{
29	_cancellationTokenSource.Dispose();	×
30	}
31	}	×
32
33	private async Task StartGameLoopUpdateAsync(CancellationToken cancelToken)
34	{
35	while (_gameLoopContext.HasNextIteration)
36	{
37	cancelToken.ThrowIfCancellationRequested();
38
39	try
40	{
41	await _gameLoopContext.UpdateAsync(cancelToken);
42	}
43	catch (Exception exception)
44	{
45	ErrorOccured?.Invoke(this, new ErrorOccuredEventArgs(exception));
46	}
47
48	var animationBlockerTask = _animationBlockerService.WaitBlockersAsync();
49	var fuseDelayTask = Task.Delay(10_000, cancelToken);
50
51	await Task.WhenAny(animationBlockerTask, fuseDelayTask).ConfigureAwait(false);
52	_animationBlockerService.DropBlockers();
53	}
54	}
55
56	public bool IsStarted { get; private set; }
57
58	public event EventHandler<ErrorOccuredEventArgs>? ErrorOccured;
59
60	public void Start()
61	{
62	_cancellationTokenSource = new CancellationTokenSource();	×
63
64	var cancelToken = _cancellationTokenSource.Token;	×
65
66	var updateTask = StartGameLoopUpdateAsync(cancelToken);	×
67
68	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnFaulted);	×
69	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnCanceled);	×
70	updateTask.ContinueWith(task => IsStarted = false, TaskContinuationOptions.OnlyOnRanToCompletion);	×
71
72	IsStarted = true;	×
73	}	×
74
75	public void Stop()
76	{
77	if (_cancellationTokenSource != null)	×
78	{
79	_cancellationTokenSource.Cancel();	×
80	}
81	}	×
82	}
83	}

kreghek / Zilon_Roguelike / 816476018

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous