[r] to new C# style and async

Author: i4004

src/Simplify.Mail.TestConsoleApp/Program.cs

@@ -11,5 +11,5 @@
 using var scope = provider.BeginLifetimeScope();
 var sender = scope.Resolver.Resolve<IMailSender>();
 
-sender.Send("[email protected]", "[email protected]", "Hello subject",
+await sender.SendAsync("[email protected]", "[email protected]", "Hello subject",
 	"Hello World!!!");

….IntegrationTester/BasicTaskProcessor.cs …grationTester/BasicTaskProcessorAsync.cssrc/Simplify.Scheduler.IntegrationTester/BasicTaskProcessor.cs renamed to src/Simplify.Scheduler.IntegrationTester/BasicTaskProcessorAsync.cs src/Simplify.Scheduler.IntegrationTester/BasicTaskProcessor.cs renamed to src/Simplify.Scheduler.IntegrationTester/BasicTaskProcessorAsync.cs

@@ -1,28 +1,26 @@
 using System;
 using System.Diagnostics;
+using System.Threading.Tasks;
 
 namespace Simplify.Scheduler.IntegrationTester;
 
-public class BasicTaskProcessor : IDisposable
+public class BasicTaskProcessorAsync(DisposableDependency dependency) : IDisposable
 {
 	private static bool _isRunning;
 
-	private readonly DisposableDependency _dependency;
-
-	public BasicTaskProcessor(DisposableDependency dependency) => _dependency = dependency;
-
-	public void Run()
+	public Task Run()
 	{
 		if (_isRunning)
 			throw new SimplifySchedulerException("BasicTaskProcessor is running a duplicate!");
 
 		_isRunning = true;
 
 		Trace.WriteLine("BasicTaskProcessor launched");
-	}
 
-	public void Dispose()
-	{
-		Trace.WriteLine("BasicTaskProcessor disposed");
+		dependency.DoSomeWork();
+
+		return Task.CompletedTask;
 	}
+
+	public void Dispose() => Trace.WriteLine("BasicTaskProcessor disposed");
 }

src/Simplify.Scheduler.IntegrationTester/DisposableDependency.cs

@@ -5,5 +5,7 @@ namespace Simplify.Scheduler.IntegrationTester;
 
 public class DisposableDependency : IDisposable
 {
+	public void DoSomeWork() { }
+
 	public void Dispose() => Trace.WriteLine("Disposable dependency disposed");
 }

src/Simplify.Scheduler.IntegrationTester/Program.cs

@@ -6,26 +6,29 @@
 
 // IOC container setup
 
-DIContainer.Current.RegisterAll()
+DIContainer.Current
+	.RegisterAll()
 	.Verify();
 
 // Using scheduler
 
-using (var scheduler = new MultitaskScheduler())
-{
-	scheduler.OnJobStart += HandlerDiagnostics.HandlerOnJobStart;
-	scheduler.OnJobFinish += HandlerDiagnostics.HandlerOnJobFinish;
+using var scheduler = new MultitaskScheduler();
 
-	scheduler.AddJob<OneSecondStepProcessor>(IocRegistrations.Configuration);
-	scheduler.AddJob<TwoSecondStepProcessor>(IocRegistrations.Configuration, startupArgs: "Hello world!!!");
-	scheduler.AddJob<OneMinuteStepCrontabProcessor>(IocRegistrations.Configuration);
-	scheduler.AddJob<TwoParallelTasksProcessor>(IocRegistrations.Configuration, invokeMethodName: "Execute");
-	scheduler.AddBasicJob<BasicTaskProcessor>();
+scheduler.OnJobStart += HandlerDiagnostics.HandlerOnJobStart;
+scheduler.OnJobFinish += HandlerDiagnostics.HandlerOnJobFinish;
+
+scheduler.AddJob<OneSecondStepProcessor>(IocRegistrations.Configuration);
+scheduler.AddJob<TwoSecondStepProcessor>(IocRegistrations.Configuration, startupArgs: "Hello world!!!");
+scheduler.AddJob<OneMinuteStepCrontabProcessor>(IocRegistrations.Configuration);
+scheduler.AddJob<TwoParallelTasksProcessor>(IocRegistrations.Configuration, invokeMethodName: "Execute");
+scheduler.AddBasicJob<BasicTaskProcessorAsync>();
+
+if (await scheduler.StartAsync(args))
+	return;
 
-	if (await scheduler.StartAsync(args))
-		return;
-}
 
 // Testing some processors without scheduler
-using (var scope = DIContainer.Current.BeginLifetimeScope())
-	scope.Resolver.Resolve<BasicTaskProcessor>().Run();
+
+using var scope = DIContainer.Current.BeginLifetimeScope();
+
+await scope.Resolver.Resolve<BasicTaskProcessorAsync>().Run();

src/Simplify.Scheduler.IntegrationTester/Setup/IocRegistrations.cs

@@ -15,7 +15,7 @@ public static IDIContainerProvider RegisterAll(this IDIContainerProvider provide
 			.Register<TwoSecondStepProcessor>()
 			.Register<OneMinuteStepCrontabProcessor>()
 			.Register<TwoParallelTasksProcessor>()
-			.Register<BasicTaskProcessor>();
+			.Register<BasicTaskProcessorAsync>();
 
 		return provider;
 	}