feat: async chain end to end

samples/ApiAudit/Trax.Samples.ApiAudit/Trains/EchoTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Core.Junction;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
@@ -13,7 +14,8 @@ public interface IEchoTrain : IServiceTrain<EchoInput, EchoOutput>;
 [TraxQuery]
 public class EchoTrain : ServiceTrain<EchoInput, EchoOutput>, IEchoTrain
 {
-    protected override EchoOutput Junctions() => Chain<EchoJunction>();
+    protected override Task<Either<Exception, EchoOutput>> Junctions() =>
+        Chain<EchoJunction>().Resolve();
 }
 
 public class EchoJunction : Junction<EchoInput, EchoOutput>

samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.CreateChatRoom.Junctions;
@@ -10,6 +11,6 @@ public class CreateChatRoomTrain
     : ServiceTrain<CreateChatRoomInput, CreateChatRoomOutput>,
         ICreateChatRoomTrain
 {
-    protected override CreateChatRoomOutput Junctions() =>
-        Chain<ValidateInputJunction>().Chain<PersistRoomJunction>();
+    protected override Task<Either<Exception, CreateChatRoomOutput>> Junctions() =>
+        Chain<ValidateInputJunction>().Chain<PersistRoomJunction>().Resolve();
 }

samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.GetChatHistory.Junctions;
@@ -9,5 +10,6 @@ public class GetChatHistoryTrain
     : ServiceTrain<GetChatHistoryInput, GetChatHistoryOutput>,
         IGetChatHistoryTrain
 {
-    protected override GetChatHistoryOutput Junctions() => Chain<FetchMessagesJunction>();
+    protected override Task<Either<Exception, GetChatHistoryOutput>> Junctions() =>
+        Chain<FetchMessagesJunction>().Resolve();
 }

samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.GetChatRooms.Junctions;
@@ -9,5 +10,6 @@ public class GetChatRoomsTrain
     : ServiceTrain<GetChatRoomsInput, GetChatRoomsOutput>,
         IGetChatRoomsTrain
 {
-    protected override GetChatRoomsOutput Junctions() => Chain<FetchRoomsJunction>();
+    protected override Task<Either<Exception, GetChatRoomsOutput>> Junctions() =>
+        Chain<FetchRoomsJunction>().Resolve();
 }

samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.JoinChatRoom.Junctions;
@@ -10,6 +11,6 @@ public class JoinChatRoomTrain
     : ServiceTrain<JoinChatRoomInput, JoinChatRoomOutput>,
         IJoinChatRoomTrain
 {
-    protected override JoinChatRoomOutput Junctions() =>
-        Chain<ValidateJoinJunction>().Chain<AddParticipantJunction>();
+    protected override Task<Either<Exception, JoinChatRoomOutput>> Junctions() =>
+        Chain<ValidateJoinJunction>().Chain<AddParticipantJunction>().Resolve();
 }

samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs

@@ -8,5 +8,6 @@ namespace Trax.Samples.ChatService.Trains.MarkChatAsRead;
 [TraxMutation(Description = "Marks a chat room as read for a user")]
 public class MarkChatAsReadTrain : ServiceTrain<MarkChatAsReadInput, Unit>, IMarkChatAsReadTrain
 {
-    protected override Unit Junctions() => Chain<UpdateLastReadJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<UpdateLastReadJunction>().Resolve();
 }

samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.SendMessage.Junctions;
@@ -8,6 +9,6 @@ namespace Trax.Samples.ChatService.Trains.SendMessage;
 [TraxBroadcast]
 public class SendMessageTrain : ServiceTrain<SendMessageInput, SendMessageOutput>, ISendMessageTrain
 {
-    protected override SendMessageOutput Junctions() =>
-        Chain<ValidateSenderJunction>().Chain<PersistMessageJunction>();
+    protected override Task<Either<Exception, SendMessageOutput>> Junctions() =>
+        Chain<ValidateSenderJunction>().Chain<PersistMessageJunction>().Resolve();
 }

samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs

@@ -12,5 +12,6 @@ public class DataProcessingTrain
     : ServiceTrain<DataProcessingPipelineInput, Unit>,
         IDataProcessingTrain
 {
-    protected override Unit Junctions() => Chain<ExecuteDataProcessingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ExecuteDataProcessingJunction>().Resolve();
 }

samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs

@@ -10,5 +10,6 @@ namespace Trax.Samples.Flowthru.Spaceflights.Trains.DataScience;
 /// </summary>
 public class DataScienceTrain : ServiceTrain<DataSciencePipelineInput, Unit>, IDataScienceTrain
 {
-    protected override Unit Junctions() => Chain<ExecuteDataScienceJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ExecuteDataScienceJunction>().Resolve();
 }

samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs

@@ -10,5 +10,6 @@ namespace Trax.Samples.Flowthru.Spaceflights.Trains.Reporting;
 /// </summary>
 public class ReportingTrain : ServiceTrain<ReportingPipelineInput, Unit>, IReportingTrain
 {
-    protected override Unit Junctions() => Chain<ExecuteReportingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ExecuteReportingJunction>().Resolve();
 }

samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.BatteryStorage.ManageBatteryStorage.Junctions;
@@ -19,6 +20,6 @@ public class ManageBatteryStorageTrain
     : ServiceTrain<ManageBatteryStorageInput, ManageBatteryStorageOutput>,
         IManageBatteryStorageTrain
 {
-    protected override ManageBatteryStorageOutput Junctions() =>
-        Chain<ReadBatteryStateJunction>().Chain<OptimizeChargeLevelJunction>();
+    protected override Task<Either<Exception, ManageBatteryStorageOutput>> Junctions() =>
+        Chain<ReadBatteryStateJunction>().Chain<OptimizeChargeLevelJunction>().Resolve();
 }

samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.ChargingSessions.ProcessChargingSession.Junctions;
@@ -15,6 +16,6 @@ public class ProcessChargingSessionTrain
     : ServiceTrain<ProcessChargingSessionInput, ProcessChargingSessionOutput>,
         IProcessChargingSessionTrain
 {
-    protected override ProcessChargingSessionOutput Junctions() =>
-        Chain<CollectSessionDataJunction>().Chain<CalculateBillingJunction>();
+    protected override Task<Either<Exception, ProcessChargingSessionOutput>> Junctions() =>
+        Chain<CollectSessionDataJunction>().Chain<CalculateBillingJunction>().Resolve();
 }

samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.GridTrading.TradeGridEnergy.Junctions;
@@ -19,6 +20,6 @@ public class TradeGridEnergyTrain
     : ServiceTrain<TradeGridEnergyInput, TradeGridEnergyOutput>,
         ITradeGridEnergyTrain
 {
-    protected override TradeGridEnergyOutput Junctions() =>
-        Chain<CalculateExcessJunction>().Chain<SubmitToUbossJunction>();
+    protected override Task<Either<Exception, TradeGridEnergyOutput>> Junctions() =>
+        Chain<CalculateExcessJunction>().Chain<SubmitToUbossJunction>().Resolve();
 }

samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs

@@ -19,6 +19,6 @@ public class OptimizeMicrogridTrain
     : ServiceTrain<OptimizeMicrogridInput, Unit>,
         IOptimizeMicrogridTrain
 {
-    protected override Unit Junctions() =>
-        Chain<GatherEnergyMetricsJunction>().Chain<ApplyDistributionJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<GatherEnergyMetricsJunction>().Chain<ApplyDistributionJunction>().Resolve();
 }

samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.SolarProduction.MonitorSolarProduction.Junctions;
@@ -14,6 +15,6 @@ public class MonitorSolarProductionTrain
     : ServiceTrain<MonitorSolarProductionInput, MonitorSolarProductionOutput>,
         IMonitorSolarProductionTrain
 {
-    protected override MonitorSolarProductionOutput Junctions() =>
-        Chain<ReadSolarSensorsJunction>().Chain<CalculateOutputJunction>();
+    protected override Task<Either<Exception, MonitorSolarProductionOutput>> Junctions() =>
+        Chain<ReadSolarSensorsJunction>().Chain<CalculateOutputJunction>().Resolve();
 }

samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.Sustainability.GenerateSustainabilityReport.Junctions;
@@ -18,6 +19,6 @@ public class GenerateSustainabilityReportTrain
     : ServiceTrain<GenerateSustainabilityReportInput, GenerateSustainabilityReportOutput>,
         IGenerateSustainabilityReportTrain
 {
-    protected override GenerateSustainabilityReportOutput Junctions() =>
-        Chain<AggregateMetricsJunction>().Chain<PublishReportJunction>();
+    protected override Task<Either<Exception, GenerateSustainabilityReportOutput>> Junctions() =>
+        Chain<AggregateMetricsJunction>().Chain<PublishReportJunction>().Resolve();
 }

samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.ContentReview.LookupModerationResult.Junctions;
@@ -14,5 +15,6 @@ public class LookupModerationResultTrain
     : ServiceTrain<LookupModerationResultInput, ModerationResult>,
         ILookupModerationResultTrain
 {
-    protected override ModerationResult Junctions() => Chain<FetchModerationResultJunction>();
+    protected override Task<Either<Exception, ModerationResult>> Junctions() =>
+        Chain<FetchModerationResultJunction>().Resolve();
 }

samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.ContentReview.ReviewContent.Junctions;
@@ -22,6 +23,9 @@ public class ReviewContentTrain
     : ServiceTrain<ReviewContentInput, ReviewContentOutput>,
         IReviewContentTrain
 {
-    protected override ReviewContentOutput Junctions() =>
-        Chain<ClassifyContentJunction>().Chain<ScoreContentJunction>().Chain<FlagContentJunction>();
+    protected override Task<Either<Exception, ReviewContentOutput>> Junctions() =>
+        Chain<ClassifyContentJunction>()
+            .Chain<ScoreContentJunction>()
+            .Chain<FlagContentJunction>()
+            .Resolve();
 }

samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.Notices.SendViolationNotice.Junctions;
@@ -21,6 +22,6 @@ public class SendViolationNoticeTrain
     : ServiceTrain<SendViolationNoticeInput, SendViolationNoticeOutput>,
         ISendViolationNoticeTrain
 {
-    protected override SendViolationNoticeOutput Junctions() =>
-        Chain<ComposeNoticeJunction>().Chain<DeliverNoticeJunction>();
+    protected override Task<Either<Exception, SendViolationNoticeOutput>> Junctions() =>
+        Chain<ComposeNoticeJunction>().Chain<DeliverNoticeJunction>().Resolve();
 }

samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.Reports.GenerateModerationReport.Junctions;
@@ -15,6 +16,6 @@ public class GenerateModerationReportTrain
     : ServiceTrain<GenerateModerationReportInput, GenerateModerationReportOutput>,
         IGenerateModerationReportTrain
 {
-    protected override GenerateModerationReportOutput Junctions() =>
-        Chain<AggregateMetricsJunction>().Chain<FormatReportJunction>();
+    protected override Task<Either<Exception, GenerateModerationReportOutput>> Junctions() =>
+        Chain<AggregateMetricsJunction>().Chain<FormatReportJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/AddJob/AddJobTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.AddJob.Junctions;
@@ -8,8 +9,9 @@ namespace Trax.Samples.JobHunt.Trains.AddJob;
 [TraxBroadcast]
 public class AddJobTrain : ServiceTrain<AddJobInput, AddJobOutput>, IAddJobTrain
 {
-    protected override AddJobOutput Junctions() =>
+    protected override Task<Either<Exception, AddJobOutput>> Junctions() =>
         Chain<ValidateAddJobInputJunction>()
             .Chain<FetchJobPostingJunction>()
-            .Chain<PersistJobJunction>();
+            .Chain<PersistJobJunction>()
+            .Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/CreateApplication/CreateApplicationTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.CreateApplication.Junctions;
@@ -9,5 +10,6 @@ public class CreateApplicationTrain
     : ServiceTrain<CreateApplicationInput, CreateApplicationOutput>,
         ICreateApplicationTrain
 {
-    protected override CreateApplicationOutput Junctions() => Chain<PersistApplicationJunction>();
+    protected override Task<Either<Exception, CreateApplicationOutput>> Junctions() =>
+        Chain<PersistApplicationJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/FindContact/FindContactTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.FindContact.Junctions;
@@ -8,5 +9,6 @@ namespace Trax.Samples.JobHunt.Trains.FindContact;
 [TraxBroadcast]
 public class FindContactTrain : ServiceTrain<FindContactInput, FindContactOutput>, IFindContactTrain
 {
-    protected override FindContactOutput Junctions() => Chain<PersistContactJunction>();
+    protected override Task<Either<Exception, FindContactOutput>> Junctions() =>
+        Chain<PersistContactJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/GenerateApplicationMaterials/GenerateApplicationMaterialsTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.GenerateApplicationMaterials.Junctions;
@@ -10,9 +11,10 @@ public class GenerateApplicationMaterialsTrain
     : ServiceTrain<GenerateApplicationMaterialsInput, GenerateApplicationMaterialsOutput>,
         IGenerateApplicationMaterialsTrain
 {
-    protected override GenerateApplicationMaterialsOutput Junctions() =>
+    protected override Task<Either<Exception, GenerateApplicationMaterialsOutput>> Junctions() =>
         Chain<LoadJobAndProfileJunction>()
             .Chain<GenerateResumeJunction>()
             .Chain<GenerateCoverLetterJunction>()
-            .Chain<PersistArtifactsJunction>();
+            .Chain<PersistArtifactsJunction>()
+            .Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/GetArtifacts/GetArtifactsTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.GetArtifacts.Junctions;
@@ -9,5 +10,6 @@ public class GetArtifactsTrain
     : ServiceTrain<GetArtifactsInput, GetArtifactsOutput>,
         IGetArtifactsTrain
 {
-    protected override GetArtifactsOutput Junctions() => Chain<LoadArtifactsJunction>();
+    protected override Task<Either<Exception, GetArtifactsOutput>> Junctions() =>
+        Chain<LoadArtifactsJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/GetProfile/GetProfileTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.GetProfile.Junctions;
@@ -7,5 +8,6 @@ namespace Trax.Samples.JobHunt.Trains.GetProfile;
 [TraxQuery(Description = "Returns the user's profile or a default empty profile")]
 public class GetProfileTrain : ServiceTrain<GetProfileInput, GetProfileOutput>, IGetProfileTrain
 {
-    protected override GetProfileOutput Junctions() => Chain<LoadProfileJunction>();
+    protected override Task<Either<Exception, GetProfileOutput>> Junctions() =>
+        Chain<LoadProfileJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/ListApplications/ListApplicationsTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.ListApplications.Junctions;
@@ -9,5 +10,6 @@ public class ListApplicationsTrain
     : ServiceTrain<ListApplicationsInput, ListApplicationsOutput>,
         IListApplicationsTrain
 {
-    protected override ListApplicationsOutput Junctions() => Chain<LoadApplicationsJunction>();
+    protected override Task<Either<Exception, ListApplicationsOutput>> Junctions() =>
+        Chain<LoadApplicationsJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/ListJobs/ListJobsTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.ListJobs.Junctions;
@@ -7,5 +8,6 @@ namespace Trax.Samples.JobHunt.Trains.ListJobs;
 [TraxQuery(Description = "Lists jobs for a user, optionally filtered by status")]
 public class ListJobsTrain : ServiceTrain<ListJobsInput, ListJobsOutput>, IListJobsTrain
 {
-    protected override ListJobsOutput Junctions() => Chain<LoadJobsJunction>();
+    protected override Task<Either<Exception, ListJobsOutput>> Junctions() =>
+        Chain<LoadJobsJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/ListWatchedCompanies/ListWatchedCompaniesTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.ListWatchedCompanies.Junctions;
@@ -9,6 +10,6 @@ public class ListWatchedCompaniesTrain
     : ServiceTrain<ListWatchedCompaniesInput, ListWatchedCompaniesOutput>,
         IListWatchedCompaniesTrain
 {
-    protected override ListWatchedCompaniesOutput Junctions() =>
-        Chain<LoadWatchedCompaniesJunction>();
+    protected override Task<Either<Exception, ListWatchedCompaniesOutput>> Junctions() =>
+        Chain<LoadWatchedCompaniesJunction>().Resolve();
 }

samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllActiveJobs/MonitorAllActiveJobsTrain.cs

@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.MonitorAllActiveJobs.Junctions;
 
@@ -7,5 +8,6 @@ public class MonitorAllActiveJobsTrain
     : ServiceTrain<MonitorAllActiveJobsInput, MonitorAllActiveJobsOutput>,
         IMonitorAllActiveJobsTrain
 {
-    protected override MonitorAllActiveJobsOutput Junctions() => Chain<FanOutMonitorJunction>();
+    protected override Task<Either<Exception, MonitorAllActiveJobsOutput>> Junctions() =>
+        Chain<FanOutMonitorJunction>().Resolve();
 }