ETTaskFactory.cs 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. using System;
  2. using System.Threading;
  3. namespace ETModel
  4. {
  5. public partial struct ETTask
  6. {
  7. private static readonly ETTask CanceledTask = new Func<ETTask>(() =>
  8. {
  9. var promise = new ETTaskCompletionSource<AsyncUnit>();
  10. promise.TrySetCanceled();
  11. return new ETTask(promise);
  12. })();
  13. public static ETTask CompletedTask => new ETTask();
  14. public static ETTask FromException(Exception ex)
  15. {
  16. var promise = new ETTaskCompletionSource<AsyncUnit>();
  17. promise.TrySetException(ex);
  18. return new ETTask(promise);
  19. }
  20. public static ETTask<T> FromException<T>(Exception ex)
  21. {
  22. var promise = new ETTaskCompletionSource<T>();
  23. promise.TrySetException(ex);
  24. return new ETTask<T>(promise);
  25. }
  26. public static ETTask<T> FromResult<T>(T value)
  27. {
  28. return new ETTask<T>(value);
  29. }
  30. public static ETTask FromCanceled()
  31. {
  32. return CanceledTask;
  33. }
  34. public static ETTask<T> FromCanceled<T>()
  35. {
  36. return CanceledETTaskCache<T>.Task;
  37. }
  38. public static ETTask FromCanceled(CancellationToken token)
  39. {
  40. var promise = new ETTaskCompletionSource<AsyncUnit>();
  41. promise.TrySetException(new OperationCanceledException(token));
  42. return new ETTask(promise);
  43. }
  44. public static ETTask<T> FromCanceled<T>(CancellationToken token)
  45. {
  46. var promise = new ETTaskCompletionSource<T>();
  47. promise.TrySetException(new OperationCanceledException(token));
  48. return new ETTask<T>(promise);
  49. }
  50. /// <summary>shorthand of new UniTask[T](Func[UniTask[T]] factory)</summary>
  51. public static ETTask<T> Lazy<T>(Func<ETTask<T>> factory)
  52. {
  53. return new ETTask<T>(factory);
  54. }
  55. private static class CanceledETTaskCache<T>
  56. {
  57. public static readonly ETTask<T> Task;
  58. static CanceledETTaskCache()
  59. {
  60. var promise = new ETTaskCompletionSource<T>();
  61. promise.TrySetCanceled();
  62. Task = new ETTask<T>(promise);
  63. }
  64. }
  65. }
  66. internal static class CompletedTasks
  67. {
  68. public static readonly ETTask<bool> True = ETTask.FromResult(true);
  69. public static readonly ETTask<bool> False = ETTask.FromResult(false);
  70. public static readonly ETTask<int> Zero = ETTask.FromResult(0);
  71. public static readonly ETTask<int> MinusOne = ETTask.FromResult(-1);
  72. public static readonly ETTask<int> One = ETTask.FromResult(1);
  73. }
  74. }