blob: 565949402797a4c266d1d303a38ad12df3b73070 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Tango.Scripting.Basic
{
public class ProjectSession
{
private Action _abortAction;
private TaskCompletionSource<object> _completion;
public event EventHandler<ProjectSessionStateChangedEventArgs> StateChanged;
public ProjectSessionState State { get; set; }
public Project Project { get; set; }
public ProjectSession(Project project, Action abortAction)
{
_completion = new TaskCompletionSource<object>();
Project = project;
_abortAction = abortAction;
}
public void Abort()
{
_abortAction();
State = ProjectSessionState.Aborted;
_completion.SetException(new OperationCanceledException("Project execution aborted."));
RaiseStateChanged();
}
internal void Failed(Exception ex)
{
State = ProjectSessionState.Failed;
_completion.SetException(ex);
RaiseStateChanged(null, ex);
}
internal void Completed(object returnValue)
{
State = ProjectSessionState.Completed;
_completion.SetResult(returnValue);
RaiseStateChanged(returnValue, null);
}
private void RaiseStateChanged(object returnValue = null, Exception ex = null)
{
StateChanged?.Invoke(this,
new ProjectSessionStateChangedEventArgs()
{
ReturnValue = returnValue,
State = State,
Exception = ex
});
}
public Task<Object> WaitForCompletion()
{
return _completion.Task;
}
}
}
|