micialware/mROA
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

попытка рефактора 2

Browse Source
This commit is contained in:
micialware
2025-01-14 14:26:55 +03:00
parent d9e3e95dda
commit b4349e3abe
1 changed files with 25 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mROA/Implementation/PrepairedExecutionModule.cs
+25 -11
View File
@@ -59,11 +59,13 @@ public class PrepairedExecutionModule : IExecuteModule
result.ContinueWith(_ => result.ContinueWith(_ =>
{ {
_serialisationModule.PostResponse(new FinalCommandExecution //_serialisationModule.PostResponse(new FinalCommandExecution
{ //{
ExecutionId = exec.ExecutionId, Result = null, CommandId = command.CommandId, // ExecutionId = exec.ExecutionId, Result = null, CommandId = command.CommandId,
ClientId = command.ClientId // ClientId = command.ClientId
}); //});
PostFinalizedCallback(exec, null);
}, token); }, token);
return exec; return exec;
@@ -82,14 +84,26 @@ public class PrepairedExecutionModule : IExecuteModule
result.ContinueWith(task => result.ContinueWith(task =>
{ {
var result = task.GetType().GetProperty("Result").GetValue(task); var finalResult = task.GetType().GetProperty("Result").GetValue(task);
_serialisationModule.PostResponse(new FinalCommandExecution //_serialisationModule.PostResponse(new FinalCommandExecution
{ //{
ExecutionId = exec.ExecutionId, Result = result, CommandId = command.CommandId, // ExecutionId = exec.ExecutionId, Result = result, CommandId = command.CommandId,
ClientId = command.ClientId // ClientId = command.ClientId
}); //});
PostFinalizedCallback(exec, finalResult);
}, token); }, token);
return exec; return exec;
} }
private void PostFinalizedCallback(ICommandExecution request, object result)
{
_serialisationModule.PostResponse(new FinalCommandExecution
{
ExecutionId = request.ExecutionId,
Result = request,
CommandId = request.CommandId,
ClientId = request.ClientId
});
}
} }