mirror of
https://github.com/Relintai/mono.git
synced 2024-11-12 10:25:32 +01:00
65 lines
1.6 KiB
C#
65 lines
1.6 KiB
C#
|
using System;
|
||
|
using System.Runtime.CompilerServices;
|
||
|
|
||
|
namespace GodotTools.IdeMessaging.Utils
|
||
|
{
|
||
|
public class NotifyAwaiter<T> : INotifyCompletion
|
||
|
{
|
||
|
private Action continuation;
|
||
|
private Exception exception;
|
||
|
private T result;
|
||
|
|
||
|
public bool IsCompleted { get; private set; }
|
||
|
|
||
|
public T GetResult()
|
||
|
{
|
||
|
if (exception != null)
|
||
|
throw exception;
|
||
|
return result;
|
||
|
}
|
||
|
|
||
|
public void OnCompleted(Action continuation)
|
||
|
{
|
||
|
if (this.continuation != null)
|
||
|
throw new InvalidOperationException("This awaiter has already been listened");
|
||
|
this.continuation = continuation;
|
||
|
}
|
||
|
|
||
|
public void SetResult(T result)
|
||
|
{
|
||
|
if (IsCompleted)
|
||
|
throw new InvalidOperationException("This awaiter is already completed");
|
||
|
|
||
|
IsCompleted = true;
|
||
|
this.result = result;
|
||
|
|
||
|
continuation?.Invoke();
|
||
|
}
|
||
|
|
||
|
public void SetException(Exception exception)
|
||
|
{
|
||
|
if (IsCompleted)
|
||
|
throw new InvalidOperationException("This awaiter is already completed");
|
||
|
|
||
|
IsCompleted = true;
|
||
|
this.exception = exception;
|
||
|
|
||
|
continuation?.Invoke();
|
||
|
}
|
||
|
|
||
|
public NotifyAwaiter<T> Reset()
|
||
|
{
|
||
|
continuation = null;
|
||
|
exception = null;
|
||
|
result = default(T);
|
||
|
IsCompleted = false;
|
||
|
return this;
|
||
|
}
|
||
|
|
||
|
public NotifyAwaiter<T> GetAwaiter()
|
||
|
{
|
||
|
return this;
|
||
|
}
|
||
|
}
|
||
|
}
|