Remove InputLoopService

Author: bording

samples/unobtrusive/Core_10/Client/InputLoopService.cs

@@ -1,10 +1,9 @@
-using Client;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 
 Console.Title = "Client";
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
+
 var endpointConfiguration = new EndpointConfiguration("Samples.Unobtrusive.Client");
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.UseTransport(new LearningTransport());
@@ -15,4 +14,11 @@
 
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+await CommandSender.Start(messageSession);
+
+await host.StopAsync();

samples/unobtrusive/Core_10/Client/Program.cs

@@ -1,10 +1,8 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
-using Server;
 
 Console.Title = "Server";
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
 
 var endpointConfiguration = new EndpointConfiguration("Samples.Unobtrusive.Server");
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
@@ -16,4 +14,11 @@
 
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+await CommandSender.Start(messageSession);
+
+await host.StopAsync();

samples/unobtrusive/Core_10/Server/InputLoopService.cs

@@ -1,20 +1,26 @@
-using Client;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 
 Console.Title = "Client";
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
+
 var endpointConfiguration = new EndpointConfiguration("Samples.Unobtrusive.Client");
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.UseTransport(new LearningTransport());
 #pragma warning disable CS0618 // Type or member is obsolete
-var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>();
-dataBus.BasePath(@"..\..\..\..\DataBusShare\");
+endpointConfiguration.UseDataBus<FileShareDataBus, SystemJsonDataBusSerializer>()
+    .BasePath(@"..\..\..\..\DataBusShare\");
 #pragma warning restore CS0618 // Type or member is obsolete
 
 endpointConfiguration.ApplyCustomConventions();
 
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+await CommandSender.Start(messageSession);
+
+await host.StopAsync();

samples/unobtrusive/Core_10/Server/Program.cs

@@ -1,10 +1,8 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
-using Server;
 
 Console.Title = "Server";
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
 
 var endpointConfiguration = new EndpointConfiguration("Samples.Unobtrusive.Server");
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
@@ -18,4 +16,11 @@
 
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+await CommandSender.Start(messageSession);
+
+await host.StopAsync();