Select.Opt.Generated.cs 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213
  1. // Licensed to the .NET Foundation under one or more agreements.
  2. // The .NET Foundation licenses this file to you under the Apache 2.0 License.
  3. // See the LICENSE file in the project root for more information.
  4. using System.Threading;
  5. using System.Threading.Tasks;
  6. namespace System.Linq
  7. {
  8. public static partial class AsyncEnumerable
  9. {
  10. private sealed class CombinedSelectors2<TSource, TMiddle1, TResult> : ICombinedSelectors<TSource, TResult>
  11. {
  12. private readonly Func<TSource, TMiddle1> _selector1;
  13. private readonly Func<TMiddle1, TResult> _selector2;
  14. public CombinedSelectors2(Func<TSource, TMiddle1> selector1, Func<TMiddle1, TResult> selector2)
  15. {
  16. _selector1 = selector1;
  17. _selector2 = selector2;
  18. }
  19. public ICombinedSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, TNewResult> selector) =>
  20. new CombinedSelectors3<TSource, TMiddle1, TResult, TNewResult>(
  21. _selector1,
  22. _selector2,
  23. selector
  24. );
  25. public TResult Invoke(TSource x) => _selector2(_selector1(x));
  26. }
  27. private sealed class CombinedSelectors3<TSource, TMiddle1, TMiddle2, TResult> : ICombinedSelectors<TSource, TResult>
  28. {
  29. private readonly Func<TSource, TMiddle1> _selector1;
  30. private readonly Func<TMiddle1, TMiddle2> _selector2;
  31. private readonly Func<TMiddle2, TResult> _selector3;
  32. public CombinedSelectors3(Func<TSource, TMiddle1> selector1, Func<TMiddle1, TMiddle2> selector2, Func<TMiddle2, TResult> selector3)
  33. {
  34. _selector1 = selector1;
  35. _selector2 = selector2;
  36. _selector3 = selector3;
  37. }
  38. public ICombinedSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, TNewResult> selector) =>
  39. new CombinedSelectors4<TSource, TMiddle1, TMiddle2, TResult, TNewResult>(
  40. _selector1,
  41. _selector2,
  42. _selector3,
  43. selector
  44. );
  45. public TResult Invoke(TSource x) => _selector3(_selector2(_selector1(x)));
  46. }
  47. private sealed class CombinedSelectors4<TSource, TMiddle1, TMiddle2, TMiddle3, TResult> : ICombinedSelectors<TSource, TResult>
  48. {
  49. private readonly Func<TSource, TMiddle1> _selector1;
  50. private readonly Func<TMiddle1, TMiddle2> _selector2;
  51. private readonly Func<TMiddle2, TMiddle3> _selector3;
  52. private readonly Func<TMiddle3, TResult> _selector4;
  53. public CombinedSelectors4(Func<TSource, TMiddle1> selector1, Func<TMiddle1, TMiddle2> selector2, Func<TMiddle2, TMiddle3> selector3, Func<TMiddle3, TResult> selector4)
  54. {
  55. _selector1 = selector1;
  56. _selector2 = selector2;
  57. _selector3 = selector3;
  58. _selector4 = selector4;
  59. }
  60. public ICombinedSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, TNewResult> selector) =>
  61. new CombinedSelectors2<TSource, TResult, TNewResult>(this.Invoke, selector);
  62. public TResult Invoke(TSource x) => _selector4(_selector3(_selector2(_selector1(x))));
  63. }
  64. private sealed class CombinedAsyncSelectors2<TSource, TMiddle1, TResult> : ICombinedAsyncSelectors<TSource, TResult>
  65. {
  66. private readonly Func<TSource, ValueTask<TMiddle1>> _selector1;
  67. private readonly Func<TMiddle1, ValueTask<TResult>> _selector2;
  68. public CombinedAsyncSelectors2(Func<TSource, ValueTask<TMiddle1>> selector1, Func<TMiddle1, ValueTask<TResult>> selector2)
  69. {
  70. _selector1 = selector1;
  71. _selector2 = selector2;
  72. }
  73. public ICombinedAsyncSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, ValueTask<TNewResult>> selector) =>
  74. new CombinedAsyncSelectors3<TSource, TMiddle1, TResult, TNewResult>(
  75. _selector1,
  76. _selector2,
  77. selector
  78. );
  79. public async ValueTask<TResult> Invoke(TSource x) => await _selector2(await _selector1(x).ConfigureAwait(false)).ConfigureAwait(false);
  80. }
  81. private sealed class CombinedAsyncSelectors3<TSource, TMiddle1, TMiddle2, TResult> : ICombinedAsyncSelectors<TSource, TResult>
  82. {
  83. private readonly Func<TSource, ValueTask<TMiddle1>> _selector1;
  84. private readonly Func<TMiddle1, ValueTask<TMiddle2>> _selector2;
  85. private readonly Func<TMiddle2, ValueTask<TResult>> _selector3;
  86. public CombinedAsyncSelectors3(Func<TSource, ValueTask<TMiddle1>> selector1, Func<TMiddle1, ValueTask<TMiddle2>> selector2, Func<TMiddle2, ValueTask<TResult>> selector3)
  87. {
  88. _selector1 = selector1;
  89. _selector2 = selector2;
  90. _selector3 = selector3;
  91. }
  92. public ICombinedAsyncSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, ValueTask<TNewResult>> selector) =>
  93. new CombinedAsyncSelectors4<TSource, TMiddle1, TMiddle2, TResult, TNewResult>(
  94. _selector1,
  95. _selector2,
  96. _selector3,
  97. selector
  98. );
  99. public async ValueTask<TResult> Invoke(TSource x) => await _selector3(await _selector2(await _selector1(x).ConfigureAwait(false)).ConfigureAwait(false)).ConfigureAwait(false);
  100. }
  101. private sealed class CombinedAsyncSelectors4<TSource, TMiddle1, TMiddle2, TMiddle3, TResult> : ICombinedAsyncSelectors<TSource, TResult>
  102. {
  103. private readonly Func<TSource, ValueTask<TMiddle1>> _selector1;
  104. private readonly Func<TMiddle1, ValueTask<TMiddle2>> _selector2;
  105. private readonly Func<TMiddle2, ValueTask<TMiddle3>> _selector3;
  106. private readonly Func<TMiddle3, ValueTask<TResult>> _selector4;
  107. public CombinedAsyncSelectors4(Func<TSource, ValueTask<TMiddle1>> selector1, Func<TMiddle1, ValueTask<TMiddle2>> selector2, Func<TMiddle2, ValueTask<TMiddle3>> selector3, Func<TMiddle3, ValueTask<TResult>> selector4)
  108. {
  109. _selector1 = selector1;
  110. _selector2 = selector2;
  111. _selector3 = selector3;
  112. _selector4 = selector4;
  113. }
  114. public ICombinedAsyncSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, ValueTask<TNewResult>> selector) =>
  115. new CombinedAsyncSelectors2<TSource, TResult, TNewResult>(this.Invoke, selector);
  116. public async ValueTask<TResult> Invoke(TSource x) => await _selector4(await _selector3(await _selector2(await _selector1(x).ConfigureAwait(false)).ConfigureAwait(false)).ConfigureAwait(false)).ConfigureAwait(false);
  117. }
  118. #if !NO_DEEP_CANCELLATION
  119. private sealed class CombinedAsyncSelectorsWithCancellation2<TSource, TMiddle1, TResult> : ICombinedAsyncSelectorsWithCancellation<TSource, TResult>
  120. {
  121. private readonly Func<TSource, CancellationToken, ValueTask<TMiddle1>> _selector1;
  122. private readonly Func<TMiddle1, CancellationToken, ValueTask<TResult>> _selector2;
  123. public CombinedAsyncSelectorsWithCancellation2(Func<TSource, CancellationToken, ValueTask<TMiddle1>> selector1, Func<TMiddle1, CancellationToken, ValueTask<TResult>> selector2)
  124. {
  125. _selector1 = selector1;
  126. _selector2 = selector2;
  127. }
  128. public ICombinedAsyncSelectorsWithCancellation<TSource, TNewResult> Combine<TNewResult>(Func<TResult, CancellationToken, ValueTask<TNewResult>> selector) =>
  129. new CombinedAsyncSelectorsWithCancellation3<TSource, TMiddle1, TResult, TNewResult>(
  130. _selector1,
  131. _selector2,
  132. selector
  133. );
  134. public async ValueTask<TResult> Invoke(TSource x, CancellationToken ct) => await _selector2(await _selector1(x, ct).ConfigureAwait(false), ct).ConfigureAwait(false);
  135. }
  136. private sealed class CombinedAsyncSelectorsWithCancellation3<TSource, TMiddle1, TMiddle2, TResult> : ICombinedAsyncSelectorsWithCancellation<TSource, TResult>
  137. {
  138. private readonly Func<TSource, CancellationToken, ValueTask<TMiddle1>> _selector1;
  139. private readonly Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> _selector2;
  140. private readonly Func<TMiddle2, CancellationToken, ValueTask<TResult>> _selector3;
  141. public CombinedAsyncSelectorsWithCancellation3(Func<TSource, CancellationToken, ValueTask<TMiddle1>> selector1, Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> selector2, Func<TMiddle2, CancellationToken, ValueTask<TResult>> selector3)
  142. {
  143. _selector1 = selector1;
  144. _selector2 = selector2;
  145. _selector3 = selector3;
  146. }
  147. public ICombinedAsyncSelectorsWithCancellation<TSource, TNewResult> Combine<TNewResult>(Func<TResult, CancellationToken, ValueTask<TNewResult>> selector) =>
  148. new CombinedAsyncSelectorsWithCancellation4<TSource, TMiddle1, TMiddle2, TResult, TNewResult>(
  149. _selector1,
  150. _selector2,
  151. _selector3,
  152. selector
  153. );
  154. public async ValueTask<TResult> Invoke(TSource x, CancellationToken ct) => await _selector3(await _selector2(await _selector1(x, ct).ConfigureAwait(false), ct).ConfigureAwait(false), ct).ConfigureAwait(false);
  155. }
  156. private sealed class CombinedAsyncSelectorsWithCancellation4<TSource, TMiddle1, TMiddle2, TMiddle3, TResult> : ICombinedAsyncSelectorsWithCancellation<TSource, TResult>
  157. {
  158. private readonly Func<TSource, CancellationToken, ValueTask<TMiddle1>> _selector1;
  159. private readonly Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> _selector2;
  160. private readonly Func<TMiddle2, CancellationToken, ValueTask<TMiddle3>> _selector3;
  161. private readonly Func<TMiddle3, CancellationToken, ValueTask<TResult>> _selector4;
  162. public CombinedAsyncSelectorsWithCancellation4(Func<TSource, CancellationToken, ValueTask<TMiddle1>> selector1, Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> selector2, Func<TMiddle2, CancellationToken, ValueTask<TMiddle3>> selector3, Func<TMiddle3, CancellationToken, ValueTask<TResult>> selector4)
  163. {
  164. _selector1 = selector1;
  165. _selector2 = selector2;
  166. _selector3 = selector3;
  167. _selector4 = selector4;
  168. }
  169. public ICombinedAsyncSelectorsWithCancellation<TSource, TNewResult> Combine<TNewResult>(Func<TResult, CancellationToken, ValueTask<TNewResult>> selector) =>
  170. new CombinedAsyncSelectorsWithCancellation2<TSource, TResult, TNewResult>(this.Invoke, selector);
  171. public async ValueTask<TResult> Invoke(TSource x, CancellationToken ct) => await _selector4(await _selector3(await _selector2(await _selector1(x, ct).ConfigureAwait(false), ct).ConfigureAwait(false), ct).ConfigureAwait(false), ct).ConfigureAwait(false);
  172. }
  173. #endif
  174. }
  175. }