MockPollComponent.cs
36 lines
| 1.1 KiB
| text/x-csharp
|
CSharpLexer
/ Implab.Test / MockPollComponent.cs
cin
|
r260 | using System; | |
| using System.Threading; | |||
| using System.Threading.Tasks; | |||
| using Implab.Components; | |||
| namespace Implab.Test { | |||
| public class MockPollComponent : PollingComponent { | |||
| public Func<CancellationToken,Task> PollWorker { get; set;} | |||
| public Func<CancellationToken, Task> StartWorker { get; set; } | |||
| public Func<CancellationToken, Task> StopWorker { get; set; } | |||
| public MockPollComponent(bool initialized) : base(initialized) { | |||
| } | |||
| protected async override Task Poll(CancellationToken ct) { | |||
| if(PollWorker!= null) | |||
| await PollWorker.Invoke(ct); | |||
| } | |||
| protected async override Task StopInternalAsync(CancellationToken ct) { | |||
|
cin
|
r262 | await base.StopInternalAsync(ct); | |
|
cin
|
r260 | if (StopWorker != null) | |
| await StopWorker.Invoke(ct); | |||
| } | |||
| protected async override Task StartInternalAsync(CancellationToken ct) { | |||
|
cin
|
r262 | await base.StartInternalAsync(ct); | |
|
cin
|
r260 | if (StartWorker != null) | |
| await StartWorker.Invoke(ct); | |||
| } | |||
| } | |||
| } |