• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

djsuperchief / Kyameru / 17822349975

18 Sep 2025 08:10AM UTC coverage: 87.183% (-0.7%) from 87.848%
17822349975

push

github

web-flow
Merge pull request #204 from djsuperchief/202-create-exchange

#202, #203 create exchange and router for internal messaging.

518 of 660 branches covered (78.48%)

Branch coverage included in aggregate %.

173 of 211 new or added lines in 16 files covered. (81.99%)

2 existing lines in 1 file now uncovered.

3019 of 3397 relevant lines covered (88.87%)

23.35 hits per line

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

80.56
/source/core/Kyameru.Core/Entities/ProcessableDelegate.cs
1
using System;
2
using System.Threading;
3
using System.Threading.Tasks;
4
using Kyameru.Core.Entities;
5

6
namespace Kyameru.Core.Entities
7
{
8
    internal class ProcessableDelegate : IProcessor
9
    {
10
        public event EventHandler<Log> OnLog;
11

12
        private Action<Routable> processAction;
13
        private readonly Func<Routable, Task> processFunc;
14

15
        public ProcessableDelegate(Action<Routable> processor)
20✔
16
        {
20✔
17
            processAction = processor;
20✔
18
        }
20✔
19

20
        public ProcessableDelegate(Func<Routable, Task> processor)
5✔
21
        {
5✔
22
            processFunc = processor;
5✔
23
        }
5✔
24
        public async Task ProcessAsync(Routable routable, CancellationToken cancellationToken)
25
        {
17✔
26
            if (!cancellationToken.IsCancellationRequested)
17✔
27
            {
17✔
28
                OnLog?.Invoke(this, new Entities.Log(Microsoft.Extensions.Logging.LogLevel.Information, "Running process delegate"));
17!
29
                try
30
                {
17✔
31
                    if (processAction != null)
17✔
32
                    {
15✔
33
                        processAction.Invoke(routable);
15✔
34
                    }
15✔
35
                    else
36
                    {
2✔
37
                        await processFunc.Invoke(routable);
2✔
38
                    }
2✔
39
                }
17✔
NEW
40
                catch (Exception ex)
×
UNCOV
41
                {
×
NEW
42
                    OnLog?.Invoke(this, new Entities.Log(Microsoft.Extensions.Logging.LogLevel.Error, ex.ToString(), ex));
×
UNCOV
43
                }
×
44
                
45
            }
17✔
46

47
            await Task.CompletedTask;
17✔
48
        }
17✔
49
    }
50
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc