8911846789

Committed 01 May 2024 04:13PM UTC coverage: 91.381% (+4.1%) from 87.327%

Build # 8911846789

Build Type

Pull #151

github

Committed by

web-flow

Commit Message

Merge 464df130b into 1fc949061

Pull Request Pull Request #151: 146 remove synchronous methods

Run Details

409 of 492 branches covered (83.13%)

Branch coverage included in aggregate %.

84 of 92 new or added lines in 14 files covered. (91.3%)

26 existing lines in 6 files now uncovered.

2231 of 2397 relevant lines covered (93.07%)

22.97 hits per line

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

62.5

/tests/UnitTests/Kyameru.Component.Error/From.cs

﻿using Kyameru.Core;
using Kyameru.Core.Contracts;
using Kyameru.Core.Entities;
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Kyameru.Core.Sys;

namespace Kyameru.Component.Error
{
    public class From : BaseError, IFromComponent
    {
        public event EventHandler<Routable> OnAction;

        public event EventHandler<Log> OnLog;
        public event AsyncEventHandler<RoutableEventData> OnActionAsync;

        public From(Dictionary<string, string> headers) : base(headers)
        {
        }

        public void Setup()
        {
            this.OnLog?.Invoke(this, new Log(Microsoft.Extensions.Logging.LogLevel.Information, "Setup"));
        }

        public void Start()
        {
            if (this.WillError())
            {
                throw new NotImplementedException();
            }

            Routable routable = new Routable(this.headers, "Test Data");
            this.OnAction?.Invoke(this, routable);
        }

        public void Stop()
        {
            // nothing to do.
        }

        public async Task StartAsync(CancellationToken cancellationToken)
        {
            if (!cancellationToken.IsCancellationRequested)
            {
                if (this.WillError())
                {
                    throw new NotImplementedException();
                }

                Routable routable = new Routable(this.headers, "Test Data");
                await this.OnActionAsync?.Invoke(this, new RoutableEventData(routable, cancellationToken));
            }

        }

        public async Task StopAsync(CancellationToken cancellationToken)
        {
            // do nothing
            await Task.CompletedTask;
        }
    }
}

1	using Kyameru.Core;
2	using Kyameru.Core.Contracts;
3	using Kyameru.Core.Entities;
4	using System;
5	using System.Collections.Generic;
6	using System.Text;
7	using System.Threading;
8	using System.Threading.Tasks;
9	using Kyameru.Core.Sys;
10
11	namespace Kyameru.Component.Error
12	{
13	public class From : BaseError, IFromComponent
14	{
15	public event EventHandler<Routable> OnAction;
16
17	public event EventHandler<Log> OnLog;
18	public event AsyncEventHandler<RoutableEventData> OnActionAsync;
19
20	public From(Dictionary<string, string> headers) : base(headers)	6✔
21	{	6✔
22	}	6✔
23
24	public void Setup()
25	{	6✔
26	this.OnLog?.Invoke(this, new Log(Microsoft.Extensions.Logging.LogLevel.Information, "Setup"));	6!
27	}	6✔
28
29	public void Start()
UNCOV 30	{	×
UNCOV 31	if (this.WillError())	×
UNCOV 32	{	×
UNCOV 33	throw new NotImplementedException();	×
34	}
35
UNCOV 36	Routable routable = new Routable(this.headers, "Test Data");	×
UNCOV 37	this.OnAction?.Invoke(this, routable);	×
UNCOV 38	}	×
39
40	public void Stop()
UNCOV 41	{	×
42	// nothing to do.
UNCOV 43	}	×
44
45	public async Task StartAsync(CancellationToken cancellationToken)
46	{	6✔
47	if (!cancellationToken.IsCancellationRequested)	6✔
48	{	6✔
49	if (this.WillError())	6✔
50	{	2✔
51	throw new NotImplementedException();	2✔
52	}
53
54	Routable routable = new Routable(this.headers, "Test Data");	4✔
55	await this.OnActionAsync?.Invoke(this, new RoutableEventData(routable, cancellationToken));	4!
56	}	4✔
57
58	}	4✔
59
60	public async Task StopAsync(CancellationToken cancellationToken)
61	{	5✔
62	// do nothing
63	await Task.CompletedTask;	5✔
64	}	5✔
65	}
66	}

djsuperchief / Kyameru / 8911846789

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