Delphi/delphimvcframework
1
0
Fork 0
mirror of https://github.com/danieleteti/delphimvcframework.git synced 2024-11-15 07:45:54 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added "Always" callback in the MVCAsync

Browse Source
This commit is contained in:
Daniele Teti 2024-07-28 23:25:12 +02:00
parent b422dc610e
commit 2e05917df3
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
sources/MVCFramework.AsyncTask.pas
View File

@ -34,6 +34,7 @@ type
TMVCAsyncBackgroundTask<T> = reference to function: T; TMVCAsyncBackgroundTask<T> = reference to function: T;
TMVCAsyncSuccessCallback<T> = reference to procedure(const BackgroundTaskResult: T); TMVCAsyncSuccessCallback<T> = reference to procedure(const BackgroundTaskResult: T);
TMVCAsyncErrorCallback = reference to procedure(const Expt: Exception); TMVCAsyncErrorCallback = reference to procedure(const Expt: Exception);
TMVCAsyncAlwaysCallback = reference to procedure;
TMVCAsyncDefaultErrorCallback = reference to procedure(const Expt: Exception; TMVCAsyncDefaultErrorCallback = reference to procedure(const Expt: Exception;
const ExptAddress: Pointer); const ExptAddress: Pointer);
@ -42,7 +43,8 @@ type
class function Run<T>( class function Run<T>(
Task: TMVCAsyncBackgroundTask<T>; Task: TMVCAsyncBackgroundTask<T>;
Success: TMVCAsyncSuccessCallback<T>; Success: TMVCAsyncSuccessCallback<T>;
Error: TMVCAsyncErrorCallback = nil): ITask; Error: TMVCAsyncErrorCallback = nil;
Always: TMVCAsyncAlwaysCallback = nil): ITask;
end; end;
var var
@ -66,7 +68,8 @@ uses
class function MVCAsync.Run<T>( class function MVCAsync.Run<T>(
Task: TMVCAsyncBackgroundTask<T>; Task: TMVCAsyncBackgroundTask<T>;
Success: TMVCAsyncSuccessCallback<T>; Success: TMVCAsyncSuccessCallback<T>;
Error: TMVCAsyncErrorCallback): ITask; Error: TMVCAsyncErrorCallback;
Always: TMVCAsyncAlwaysCallback): ITask;
var var
LRes: T; LRes: T;
begin begin
@ -98,14 +101,26 @@ begin
LCurrException := Exception(Ex); LCurrException := Exception(Ex);
try try
if Assigned(Error) then if Assigned(Error) then
Error(LCurrException) begin
Error(LCurrException);
end
else else
begin
gDefaultTaskErrorHandler(LCurrException, ExceptionAddress); gDefaultTaskErrorHandler(LCurrException, ExceptionAddress);
end;
finally finally
FreeAndNil(LCurrException); FreeAndNil(LCurrException);
end; end;
end); end);
end; end;
if Assigned(Always) then
begin
TThread.Queue(nil,
procedure
begin
Always();
end);
end;
end); end);
end; end;