MinMax.Generated.cs 43 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134
  1. // Licensed to the .NET Foundation under one or more agreements.
  2. // The .NET Foundation licenses this file to you under the MIT license.
  3. // See the LICENSE file in the project root for more information.
  4. using System.Collections.Generic;
  5. using System.Threading;
  6. using System.Threading.Tasks;
  7. namespace System.Linq
  8. {
  9. public static partial class AsyncEnumerable
  10. {
  11. public static Task<int> Max(this IAsyncEnumerable<int> source)
  12. {
  13. if (source == null)
  14. throw Error.ArgumentNull(nameof(source));
  15. return MaxCore(source, CancellationToken.None);
  16. }
  17. public static Task<int> Max(this IAsyncEnumerable<int> source, CancellationToken cancellationToken)
  18. {
  19. if (source == null)
  20. throw Error.ArgumentNull(nameof(source));
  21. return MaxCore(source, cancellationToken);
  22. }
  23. public static Task<int> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector)
  24. {
  25. if (source == null)
  26. throw Error.ArgumentNull(nameof(source));
  27. if (selector == null)
  28. throw Error.ArgumentNull(nameof(selector));
  29. return MaxCore(source, selector, CancellationToken.None);
  30. }
  31. public static Task<int> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector, CancellationToken cancellationToken)
  32. {
  33. if (source == null)
  34. throw Error.ArgumentNull(nameof(source));
  35. if (selector == null)
  36. throw Error.ArgumentNull(nameof(selector));
  37. return MaxCore(source, selector, cancellationToken);
  38. }
  39. public static Task<int> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int>> selector)
  40. {
  41. if (source == null)
  42. throw Error.ArgumentNull(nameof(source));
  43. if (selector == null)
  44. throw Error.ArgumentNull(nameof(selector));
  45. return MaxCore(source, selector, CancellationToken.None);
  46. }
  47. public static Task<int> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int>> selector, CancellationToken cancellationToken)
  48. {
  49. if (source == null)
  50. throw Error.ArgumentNull(nameof(source));
  51. if (selector == null)
  52. throw Error.ArgumentNull(nameof(selector));
  53. return MaxCore(source, selector, cancellationToken);
  54. }
  55. public static Task<int?> Max(this IAsyncEnumerable<int?> source)
  56. {
  57. if (source == null)
  58. throw Error.ArgumentNull(nameof(source));
  59. return MaxCore(source, CancellationToken.None);
  60. }
  61. public static Task<int?> Max(this IAsyncEnumerable<int?> source, CancellationToken cancellationToken)
  62. {
  63. if (source == null)
  64. throw Error.ArgumentNull(nameof(source));
  65. return MaxCore(source, cancellationToken);
  66. }
  67. public static Task<int?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int?> selector)
  68. {
  69. if (source == null)
  70. throw Error.ArgumentNull(nameof(source));
  71. if (selector == null)
  72. throw Error.ArgumentNull(nameof(selector));
  73. return MaxCore(source, selector, CancellationToken.None);
  74. }
  75. public static Task<int?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int?> selector, CancellationToken cancellationToken)
  76. {
  77. if (source == null)
  78. throw Error.ArgumentNull(nameof(source));
  79. if (selector == null)
  80. throw Error.ArgumentNull(nameof(selector));
  81. return MaxCore(source, selector, cancellationToken);
  82. }
  83. public static Task<int?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int?>> selector)
  84. {
  85. if (source == null)
  86. throw Error.ArgumentNull(nameof(source));
  87. if (selector == null)
  88. throw Error.ArgumentNull(nameof(selector));
  89. return MaxCore(source, selector, CancellationToken.None);
  90. }
  91. public static Task<int?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int?>> selector, CancellationToken cancellationToken)
  92. {
  93. if (source == null)
  94. throw Error.ArgumentNull(nameof(source));
  95. if (selector == null)
  96. throw Error.ArgumentNull(nameof(selector));
  97. return MaxCore(source, selector, cancellationToken);
  98. }
  99. public static Task<long> Max(this IAsyncEnumerable<long> source)
  100. {
  101. if (source == null)
  102. throw Error.ArgumentNull(nameof(source));
  103. return MaxCore(source, CancellationToken.None);
  104. }
  105. public static Task<long> Max(this IAsyncEnumerable<long> source, CancellationToken cancellationToken)
  106. {
  107. if (source == null)
  108. throw Error.ArgumentNull(nameof(source));
  109. return MaxCore(source, cancellationToken);
  110. }
  111. public static Task<long> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long> selector)
  112. {
  113. if (source == null)
  114. throw Error.ArgumentNull(nameof(source));
  115. if (selector == null)
  116. throw Error.ArgumentNull(nameof(selector));
  117. return MaxCore(source, selector, CancellationToken.None);
  118. }
  119. public static Task<long> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long> selector, CancellationToken cancellationToken)
  120. {
  121. if (source == null)
  122. throw Error.ArgumentNull(nameof(source));
  123. if (selector == null)
  124. throw Error.ArgumentNull(nameof(selector));
  125. return MaxCore(source, selector, cancellationToken);
  126. }
  127. public static Task<long> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long>> selector)
  128. {
  129. if (source == null)
  130. throw Error.ArgumentNull(nameof(source));
  131. if (selector == null)
  132. throw Error.ArgumentNull(nameof(selector));
  133. return MaxCore(source, selector, CancellationToken.None);
  134. }
  135. public static Task<long> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long>> selector, CancellationToken cancellationToken)
  136. {
  137. if (source == null)
  138. throw Error.ArgumentNull(nameof(source));
  139. if (selector == null)
  140. throw Error.ArgumentNull(nameof(selector));
  141. return MaxCore(source, selector, cancellationToken);
  142. }
  143. public static Task<long?> Max(this IAsyncEnumerable<long?> source)
  144. {
  145. if (source == null)
  146. throw Error.ArgumentNull(nameof(source));
  147. return MaxCore(source, CancellationToken.None);
  148. }
  149. public static Task<long?> Max(this IAsyncEnumerable<long?> source, CancellationToken cancellationToken)
  150. {
  151. if (source == null)
  152. throw Error.ArgumentNull(nameof(source));
  153. return MaxCore(source, cancellationToken);
  154. }
  155. public static Task<long?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long?> selector)
  156. {
  157. if (source == null)
  158. throw Error.ArgumentNull(nameof(source));
  159. if (selector == null)
  160. throw Error.ArgumentNull(nameof(selector));
  161. return MaxCore(source, selector, CancellationToken.None);
  162. }
  163. public static Task<long?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long?> selector, CancellationToken cancellationToken)
  164. {
  165. if (source == null)
  166. throw Error.ArgumentNull(nameof(source));
  167. if (selector == null)
  168. throw Error.ArgumentNull(nameof(selector));
  169. return MaxCore(source, selector, cancellationToken);
  170. }
  171. public static Task<long?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long?>> selector)
  172. {
  173. if (source == null)
  174. throw Error.ArgumentNull(nameof(source));
  175. if (selector == null)
  176. throw Error.ArgumentNull(nameof(selector));
  177. return MaxCore(source, selector, CancellationToken.None);
  178. }
  179. public static Task<long?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long?>> selector, CancellationToken cancellationToken)
  180. {
  181. if (source == null)
  182. throw Error.ArgumentNull(nameof(source));
  183. if (selector == null)
  184. throw Error.ArgumentNull(nameof(selector));
  185. return MaxCore(source, selector, cancellationToken);
  186. }
  187. public static Task<float> Max(this IAsyncEnumerable<float> source)
  188. {
  189. if (source == null)
  190. throw Error.ArgumentNull(nameof(source));
  191. return MaxCore(source, CancellationToken.None);
  192. }
  193. public static Task<float> Max(this IAsyncEnumerable<float> source, CancellationToken cancellationToken)
  194. {
  195. if (source == null)
  196. throw Error.ArgumentNull(nameof(source));
  197. return MaxCore(source, cancellationToken);
  198. }
  199. public static Task<float> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float> selector)
  200. {
  201. if (source == null)
  202. throw Error.ArgumentNull(nameof(source));
  203. if (selector == null)
  204. throw Error.ArgumentNull(nameof(selector));
  205. return MaxCore(source, selector, CancellationToken.None);
  206. }
  207. public static Task<float> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float> selector, CancellationToken cancellationToken)
  208. {
  209. if (source == null)
  210. throw Error.ArgumentNull(nameof(source));
  211. if (selector == null)
  212. throw Error.ArgumentNull(nameof(selector));
  213. return MaxCore(source, selector, cancellationToken);
  214. }
  215. public static Task<float> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float>> selector)
  216. {
  217. if (source == null)
  218. throw Error.ArgumentNull(nameof(source));
  219. if (selector == null)
  220. throw Error.ArgumentNull(nameof(selector));
  221. return MaxCore(source, selector, CancellationToken.None);
  222. }
  223. public static Task<float> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float>> selector, CancellationToken cancellationToken)
  224. {
  225. if (source == null)
  226. throw Error.ArgumentNull(nameof(source));
  227. if (selector == null)
  228. throw Error.ArgumentNull(nameof(selector));
  229. return MaxCore(source, selector, cancellationToken);
  230. }
  231. public static Task<float?> Max(this IAsyncEnumerable<float?> source)
  232. {
  233. if (source == null)
  234. throw Error.ArgumentNull(nameof(source));
  235. return MaxCore(source, CancellationToken.None);
  236. }
  237. public static Task<float?> Max(this IAsyncEnumerable<float?> source, CancellationToken cancellationToken)
  238. {
  239. if (source == null)
  240. throw Error.ArgumentNull(nameof(source));
  241. return MaxCore(source, cancellationToken);
  242. }
  243. public static Task<float?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float?> selector)
  244. {
  245. if (source == null)
  246. throw Error.ArgumentNull(nameof(source));
  247. if (selector == null)
  248. throw Error.ArgumentNull(nameof(selector));
  249. return MaxCore(source, selector, CancellationToken.None);
  250. }
  251. public static Task<float?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float?> selector, CancellationToken cancellationToken)
  252. {
  253. if (source == null)
  254. throw Error.ArgumentNull(nameof(source));
  255. if (selector == null)
  256. throw Error.ArgumentNull(nameof(selector));
  257. return MaxCore(source, selector, cancellationToken);
  258. }
  259. public static Task<float?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float?>> selector)
  260. {
  261. if (source == null)
  262. throw Error.ArgumentNull(nameof(source));
  263. if (selector == null)
  264. throw Error.ArgumentNull(nameof(selector));
  265. return MaxCore(source, selector, CancellationToken.None);
  266. }
  267. public static Task<float?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float?>> selector, CancellationToken cancellationToken)
  268. {
  269. if (source == null)
  270. throw Error.ArgumentNull(nameof(source));
  271. if (selector == null)
  272. throw Error.ArgumentNull(nameof(selector));
  273. return MaxCore(source, selector, cancellationToken);
  274. }
  275. public static Task<double> Max(this IAsyncEnumerable<double> source)
  276. {
  277. if (source == null)
  278. throw Error.ArgumentNull(nameof(source));
  279. return MaxCore(source, CancellationToken.None);
  280. }
  281. public static Task<double> Max(this IAsyncEnumerable<double> source, CancellationToken cancellationToken)
  282. {
  283. if (source == null)
  284. throw Error.ArgumentNull(nameof(source));
  285. return MaxCore(source, cancellationToken);
  286. }
  287. public static Task<double> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double> selector)
  288. {
  289. if (source == null)
  290. throw Error.ArgumentNull(nameof(source));
  291. if (selector == null)
  292. throw Error.ArgumentNull(nameof(selector));
  293. return MaxCore(source, selector, CancellationToken.None);
  294. }
  295. public static Task<double> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double> selector, CancellationToken cancellationToken)
  296. {
  297. if (source == null)
  298. throw Error.ArgumentNull(nameof(source));
  299. if (selector == null)
  300. throw Error.ArgumentNull(nameof(selector));
  301. return MaxCore(source, selector, cancellationToken);
  302. }
  303. public static Task<double> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double>> selector)
  304. {
  305. if (source == null)
  306. throw Error.ArgumentNull(nameof(source));
  307. if (selector == null)
  308. throw Error.ArgumentNull(nameof(selector));
  309. return MaxCore(source, selector, CancellationToken.None);
  310. }
  311. public static Task<double> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double>> selector, CancellationToken cancellationToken)
  312. {
  313. if (source == null)
  314. throw Error.ArgumentNull(nameof(source));
  315. if (selector == null)
  316. throw Error.ArgumentNull(nameof(selector));
  317. return MaxCore(source, selector, cancellationToken);
  318. }
  319. public static Task<double?> Max(this IAsyncEnumerable<double?> source)
  320. {
  321. if (source == null)
  322. throw Error.ArgumentNull(nameof(source));
  323. return MaxCore(source, CancellationToken.None);
  324. }
  325. public static Task<double?> Max(this IAsyncEnumerable<double?> source, CancellationToken cancellationToken)
  326. {
  327. if (source == null)
  328. throw Error.ArgumentNull(nameof(source));
  329. return MaxCore(source, cancellationToken);
  330. }
  331. public static Task<double?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double?> selector)
  332. {
  333. if (source == null)
  334. throw Error.ArgumentNull(nameof(source));
  335. if (selector == null)
  336. throw Error.ArgumentNull(nameof(selector));
  337. return MaxCore(source, selector, CancellationToken.None);
  338. }
  339. public static Task<double?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double?> selector, CancellationToken cancellationToken)
  340. {
  341. if (source == null)
  342. throw Error.ArgumentNull(nameof(source));
  343. if (selector == null)
  344. throw Error.ArgumentNull(nameof(selector));
  345. return MaxCore(source, selector, cancellationToken);
  346. }
  347. public static Task<double?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double?>> selector)
  348. {
  349. if (source == null)
  350. throw Error.ArgumentNull(nameof(source));
  351. if (selector == null)
  352. throw Error.ArgumentNull(nameof(selector));
  353. return MaxCore(source, selector, CancellationToken.None);
  354. }
  355. public static Task<double?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double?>> selector, CancellationToken cancellationToken)
  356. {
  357. if (source == null)
  358. throw Error.ArgumentNull(nameof(source));
  359. if (selector == null)
  360. throw Error.ArgumentNull(nameof(selector));
  361. return MaxCore(source, selector, cancellationToken);
  362. }
  363. public static Task<decimal> Max(this IAsyncEnumerable<decimal> source)
  364. {
  365. if (source == null)
  366. throw Error.ArgumentNull(nameof(source));
  367. return MaxCore(source, CancellationToken.None);
  368. }
  369. public static Task<decimal> Max(this IAsyncEnumerable<decimal> source, CancellationToken cancellationToken)
  370. {
  371. if (source == null)
  372. throw Error.ArgumentNull(nameof(source));
  373. return MaxCore(source, cancellationToken);
  374. }
  375. public static Task<decimal> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector)
  376. {
  377. if (source == null)
  378. throw Error.ArgumentNull(nameof(source));
  379. if (selector == null)
  380. throw Error.ArgumentNull(nameof(selector));
  381. return MaxCore(source, selector, CancellationToken.None);
  382. }
  383. public static Task<decimal> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector, CancellationToken cancellationToken)
  384. {
  385. if (source == null)
  386. throw Error.ArgumentNull(nameof(source));
  387. if (selector == null)
  388. throw Error.ArgumentNull(nameof(selector));
  389. return MaxCore(source, selector, cancellationToken);
  390. }
  391. public static Task<decimal> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal>> selector)
  392. {
  393. if (source == null)
  394. throw Error.ArgumentNull(nameof(source));
  395. if (selector == null)
  396. throw Error.ArgumentNull(nameof(selector));
  397. return MaxCore(source, selector, CancellationToken.None);
  398. }
  399. public static Task<decimal> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal>> selector, CancellationToken cancellationToken)
  400. {
  401. if (source == null)
  402. throw Error.ArgumentNull(nameof(source));
  403. if (selector == null)
  404. throw Error.ArgumentNull(nameof(selector));
  405. return MaxCore(source, selector, cancellationToken);
  406. }
  407. public static Task<decimal?> Max(this IAsyncEnumerable<decimal?> source)
  408. {
  409. if (source == null)
  410. throw Error.ArgumentNull(nameof(source));
  411. return MaxCore(source, CancellationToken.None);
  412. }
  413. public static Task<decimal?> Max(this IAsyncEnumerable<decimal?> source, CancellationToken cancellationToken)
  414. {
  415. if (source == null)
  416. throw Error.ArgumentNull(nameof(source));
  417. return MaxCore(source, cancellationToken);
  418. }
  419. public static Task<decimal?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector)
  420. {
  421. if (source == null)
  422. throw Error.ArgumentNull(nameof(source));
  423. if (selector == null)
  424. throw Error.ArgumentNull(nameof(selector));
  425. return MaxCore(source, selector, CancellationToken.None);
  426. }
  427. public static Task<decimal?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector, CancellationToken cancellationToken)
  428. {
  429. if (source == null)
  430. throw Error.ArgumentNull(nameof(source));
  431. if (selector == null)
  432. throw Error.ArgumentNull(nameof(selector));
  433. return MaxCore(source, selector, cancellationToken);
  434. }
  435. public static Task<decimal?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal?>> selector)
  436. {
  437. if (source == null)
  438. throw Error.ArgumentNull(nameof(source));
  439. if (selector == null)
  440. throw Error.ArgumentNull(nameof(selector));
  441. return MaxCore(source, selector, CancellationToken.None);
  442. }
  443. public static Task<decimal?> Max<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal?>> selector, CancellationToken cancellationToken)
  444. {
  445. if (source == null)
  446. throw Error.ArgumentNull(nameof(source));
  447. if (selector == null)
  448. throw Error.ArgumentNull(nameof(selector));
  449. return MaxCore(source, selector, cancellationToken);
  450. }
  451. public static Task<int> Min(this IAsyncEnumerable<int> source)
  452. {
  453. if (source == null)
  454. throw Error.ArgumentNull(nameof(source));
  455. return MinCore(source, CancellationToken.None);
  456. }
  457. public static Task<int> Min(this IAsyncEnumerable<int> source, CancellationToken cancellationToken)
  458. {
  459. if (source == null)
  460. throw Error.ArgumentNull(nameof(source));
  461. return MinCore(source, cancellationToken);
  462. }
  463. public static Task<int> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector)
  464. {
  465. if (source == null)
  466. throw Error.ArgumentNull(nameof(source));
  467. if (selector == null)
  468. throw Error.ArgumentNull(nameof(selector));
  469. return MinCore(source, selector, CancellationToken.None);
  470. }
  471. public static Task<int> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector, CancellationToken cancellationToken)
  472. {
  473. if (source == null)
  474. throw Error.ArgumentNull(nameof(source));
  475. if (selector == null)
  476. throw Error.ArgumentNull(nameof(selector));
  477. return MinCore(source, selector, cancellationToken);
  478. }
  479. public static Task<int> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int>> selector)
  480. {
  481. if (source == null)
  482. throw Error.ArgumentNull(nameof(source));
  483. if (selector == null)
  484. throw Error.ArgumentNull(nameof(selector));
  485. return MinCore(source, selector, CancellationToken.None);
  486. }
  487. public static Task<int> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int>> selector, CancellationToken cancellationToken)
  488. {
  489. if (source == null)
  490. throw Error.ArgumentNull(nameof(source));
  491. if (selector == null)
  492. throw Error.ArgumentNull(nameof(selector));
  493. return MinCore(source, selector, cancellationToken);
  494. }
  495. public static Task<int?> Min(this IAsyncEnumerable<int?> source)
  496. {
  497. if (source == null)
  498. throw Error.ArgumentNull(nameof(source));
  499. return MinCore(source, CancellationToken.None);
  500. }
  501. public static Task<int?> Min(this IAsyncEnumerable<int?> source, CancellationToken cancellationToken)
  502. {
  503. if (source == null)
  504. throw Error.ArgumentNull(nameof(source));
  505. return MinCore(source, cancellationToken);
  506. }
  507. public static Task<int?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int?> selector)
  508. {
  509. if (source == null)
  510. throw Error.ArgumentNull(nameof(source));
  511. if (selector == null)
  512. throw Error.ArgumentNull(nameof(selector));
  513. return MinCore(source, selector, CancellationToken.None);
  514. }
  515. public static Task<int?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int?> selector, CancellationToken cancellationToken)
  516. {
  517. if (source == null)
  518. throw Error.ArgumentNull(nameof(source));
  519. if (selector == null)
  520. throw Error.ArgumentNull(nameof(selector));
  521. return MinCore(source, selector, cancellationToken);
  522. }
  523. public static Task<int?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int?>> selector)
  524. {
  525. if (source == null)
  526. throw Error.ArgumentNull(nameof(source));
  527. if (selector == null)
  528. throw Error.ArgumentNull(nameof(selector));
  529. return MinCore(source, selector, CancellationToken.None);
  530. }
  531. public static Task<int?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<int?>> selector, CancellationToken cancellationToken)
  532. {
  533. if (source == null)
  534. throw Error.ArgumentNull(nameof(source));
  535. if (selector == null)
  536. throw Error.ArgumentNull(nameof(selector));
  537. return MinCore(source, selector, cancellationToken);
  538. }
  539. public static Task<long> Min(this IAsyncEnumerable<long> source)
  540. {
  541. if (source == null)
  542. throw Error.ArgumentNull(nameof(source));
  543. return MinCore(source, CancellationToken.None);
  544. }
  545. public static Task<long> Min(this IAsyncEnumerable<long> source, CancellationToken cancellationToken)
  546. {
  547. if (source == null)
  548. throw Error.ArgumentNull(nameof(source));
  549. return MinCore(source, cancellationToken);
  550. }
  551. public static Task<long> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long> selector)
  552. {
  553. if (source == null)
  554. throw Error.ArgumentNull(nameof(source));
  555. if (selector == null)
  556. throw Error.ArgumentNull(nameof(selector));
  557. return MinCore(source, selector, CancellationToken.None);
  558. }
  559. public static Task<long> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long> selector, CancellationToken cancellationToken)
  560. {
  561. if (source == null)
  562. throw Error.ArgumentNull(nameof(source));
  563. if (selector == null)
  564. throw Error.ArgumentNull(nameof(selector));
  565. return MinCore(source, selector, cancellationToken);
  566. }
  567. public static Task<long> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long>> selector)
  568. {
  569. if (source == null)
  570. throw Error.ArgumentNull(nameof(source));
  571. if (selector == null)
  572. throw Error.ArgumentNull(nameof(selector));
  573. return MinCore(source, selector, CancellationToken.None);
  574. }
  575. public static Task<long> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long>> selector, CancellationToken cancellationToken)
  576. {
  577. if (source == null)
  578. throw Error.ArgumentNull(nameof(source));
  579. if (selector == null)
  580. throw Error.ArgumentNull(nameof(selector));
  581. return MinCore(source, selector, cancellationToken);
  582. }
  583. public static Task<long?> Min(this IAsyncEnumerable<long?> source)
  584. {
  585. if (source == null)
  586. throw Error.ArgumentNull(nameof(source));
  587. return MinCore(source, CancellationToken.None);
  588. }
  589. public static Task<long?> Min(this IAsyncEnumerable<long?> source, CancellationToken cancellationToken)
  590. {
  591. if (source == null)
  592. throw Error.ArgumentNull(nameof(source));
  593. return MinCore(source, cancellationToken);
  594. }
  595. public static Task<long?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long?> selector)
  596. {
  597. if (source == null)
  598. throw Error.ArgumentNull(nameof(source));
  599. if (selector == null)
  600. throw Error.ArgumentNull(nameof(selector));
  601. return MinCore(source, selector, CancellationToken.None);
  602. }
  603. public static Task<long?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long?> selector, CancellationToken cancellationToken)
  604. {
  605. if (source == null)
  606. throw Error.ArgumentNull(nameof(source));
  607. if (selector == null)
  608. throw Error.ArgumentNull(nameof(selector));
  609. return MinCore(source, selector, cancellationToken);
  610. }
  611. public static Task<long?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long?>> selector)
  612. {
  613. if (source == null)
  614. throw Error.ArgumentNull(nameof(source));
  615. if (selector == null)
  616. throw Error.ArgumentNull(nameof(selector));
  617. return MinCore(source, selector, CancellationToken.None);
  618. }
  619. public static Task<long?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<long?>> selector, CancellationToken cancellationToken)
  620. {
  621. if (source == null)
  622. throw Error.ArgumentNull(nameof(source));
  623. if (selector == null)
  624. throw Error.ArgumentNull(nameof(selector));
  625. return MinCore(source, selector, cancellationToken);
  626. }
  627. public static Task<float> Min(this IAsyncEnumerable<float> source)
  628. {
  629. if (source == null)
  630. throw Error.ArgumentNull(nameof(source));
  631. return MinCore(source, CancellationToken.None);
  632. }
  633. public static Task<float> Min(this IAsyncEnumerable<float> source, CancellationToken cancellationToken)
  634. {
  635. if (source == null)
  636. throw Error.ArgumentNull(nameof(source));
  637. return MinCore(source, cancellationToken);
  638. }
  639. public static Task<float> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float> selector)
  640. {
  641. if (source == null)
  642. throw Error.ArgumentNull(nameof(source));
  643. if (selector == null)
  644. throw Error.ArgumentNull(nameof(selector));
  645. return MinCore(source, selector, CancellationToken.None);
  646. }
  647. public static Task<float> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float> selector, CancellationToken cancellationToken)
  648. {
  649. if (source == null)
  650. throw Error.ArgumentNull(nameof(source));
  651. if (selector == null)
  652. throw Error.ArgumentNull(nameof(selector));
  653. return MinCore(source, selector, cancellationToken);
  654. }
  655. public static Task<float> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float>> selector)
  656. {
  657. if (source == null)
  658. throw Error.ArgumentNull(nameof(source));
  659. if (selector == null)
  660. throw Error.ArgumentNull(nameof(selector));
  661. return MinCore(source, selector, CancellationToken.None);
  662. }
  663. public static Task<float> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float>> selector, CancellationToken cancellationToken)
  664. {
  665. if (source == null)
  666. throw Error.ArgumentNull(nameof(source));
  667. if (selector == null)
  668. throw Error.ArgumentNull(nameof(selector));
  669. return MinCore(source, selector, cancellationToken);
  670. }
  671. public static Task<float?> Min(this IAsyncEnumerable<float?> source)
  672. {
  673. if (source == null)
  674. throw Error.ArgumentNull(nameof(source));
  675. return MinCore(source, CancellationToken.None);
  676. }
  677. public static Task<float?> Min(this IAsyncEnumerable<float?> source, CancellationToken cancellationToken)
  678. {
  679. if (source == null)
  680. throw Error.ArgumentNull(nameof(source));
  681. return MinCore(source, cancellationToken);
  682. }
  683. public static Task<float?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float?> selector)
  684. {
  685. if (source == null)
  686. throw Error.ArgumentNull(nameof(source));
  687. if (selector == null)
  688. throw Error.ArgumentNull(nameof(selector));
  689. return MinCore(source, selector, CancellationToken.None);
  690. }
  691. public static Task<float?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float?> selector, CancellationToken cancellationToken)
  692. {
  693. if (source == null)
  694. throw Error.ArgumentNull(nameof(source));
  695. if (selector == null)
  696. throw Error.ArgumentNull(nameof(selector));
  697. return MinCore(source, selector, cancellationToken);
  698. }
  699. public static Task<float?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float?>> selector)
  700. {
  701. if (source == null)
  702. throw Error.ArgumentNull(nameof(source));
  703. if (selector == null)
  704. throw Error.ArgumentNull(nameof(selector));
  705. return MinCore(source, selector, CancellationToken.None);
  706. }
  707. public static Task<float?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<float?>> selector, CancellationToken cancellationToken)
  708. {
  709. if (source == null)
  710. throw Error.ArgumentNull(nameof(source));
  711. if (selector == null)
  712. throw Error.ArgumentNull(nameof(selector));
  713. return MinCore(source, selector, cancellationToken);
  714. }
  715. public static Task<double> Min(this IAsyncEnumerable<double> source)
  716. {
  717. if (source == null)
  718. throw Error.ArgumentNull(nameof(source));
  719. return MinCore(source, CancellationToken.None);
  720. }
  721. public static Task<double> Min(this IAsyncEnumerable<double> source, CancellationToken cancellationToken)
  722. {
  723. if (source == null)
  724. throw Error.ArgumentNull(nameof(source));
  725. return MinCore(source, cancellationToken);
  726. }
  727. public static Task<double> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double> selector)
  728. {
  729. if (source == null)
  730. throw Error.ArgumentNull(nameof(source));
  731. if (selector == null)
  732. throw Error.ArgumentNull(nameof(selector));
  733. return MinCore(source, selector, CancellationToken.None);
  734. }
  735. public static Task<double> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double> selector, CancellationToken cancellationToken)
  736. {
  737. if (source == null)
  738. throw Error.ArgumentNull(nameof(source));
  739. if (selector == null)
  740. throw Error.ArgumentNull(nameof(selector));
  741. return MinCore(source, selector, cancellationToken);
  742. }
  743. public static Task<double> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double>> selector)
  744. {
  745. if (source == null)
  746. throw Error.ArgumentNull(nameof(source));
  747. if (selector == null)
  748. throw Error.ArgumentNull(nameof(selector));
  749. return MinCore(source, selector, CancellationToken.None);
  750. }
  751. public static Task<double> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double>> selector, CancellationToken cancellationToken)
  752. {
  753. if (source == null)
  754. throw Error.ArgumentNull(nameof(source));
  755. if (selector == null)
  756. throw Error.ArgumentNull(nameof(selector));
  757. return MinCore(source, selector, cancellationToken);
  758. }
  759. public static Task<double?> Min(this IAsyncEnumerable<double?> source)
  760. {
  761. if (source == null)
  762. throw Error.ArgumentNull(nameof(source));
  763. return MinCore(source, CancellationToken.None);
  764. }
  765. public static Task<double?> Min(this IAsyncEnumerable<double?> source, CancellationToken cancellationToken)
  766. {
  767. if (source == null)
  768. throw Error.ArgumentNull(nameof(source));
  769. return MinCore(source, cancellationToken);
  770. }
  771. public static Task<double?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double?> selector)
  772. {
  773. if (source == null)
  774. throw Error.ArgumentNull(nameof(source));
  775. if (selector == null)
  776. throw Error.ArgumentNull(nameof(selector));
  777. return MinCore(source, selector, CancellationToken.None);
  778. }
  779. public static Task<double?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double?> selector, CancellationToken cancellationToken)
  780. {
  781. if (source == null)
  782. throw Error.ArgumentNull(nameof(source));
  783. if (selector == null)
  784. throw Error.ArgumentNull(nameof(selector));
  785. return MinCore(source, selector, cancellationToken);
  786. }
  787. public static Task<double?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double?>> selector)
  788. {
  789. if (source == null)
  790. throw Error.ArgumentNull(nameof(source));
  791. if (selector == null)
  792. throw Error.ArgumentNull(nameof(selector));
  793. return MinCore(source, selector, CancellationToken.None);
  794. }
  795. public static Task<double?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<double?>> selector, CancellationToken cancellationToken)
  796. {
  797. if (source == null)
  798. throw Error.ArgumentNull(nameof(source));
  799. if (selector == null)
  800. throw Error.ArgumentNull(nameof(selector));
  801. return MinCore(source, selector, cancellationToken);
  802. }
  803. public static Task<decimal> Min(this IAsyncEnumerable<decimal> source)
  804. {
  805. if (source == null)
  806. throw Error.ArgumentNull(nameof(source));
  807. return MinCore(source, CancellationToken.None);
  808. }
  809. public static Task<decimal> Min(this IAsyncEnumerable<decimal> source, CancellationToken cancellationToken)
  810. {
  811. if (source == null)
  812. throw Error.ArgumentNull(nameof(source));
  813. return MinCore(source, cancellationToken);
  814. }
  815. public static Task<decimal> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector)
  816. {
  817. if (source == null)
  818. throw Error.ArgumentNull(nameof(source));
  819. if (selector == null)
  820. throw Error.ArgumentNull(nameof(selector));
  821. return MinCore(source, selector, CancellationToken.None);
  822. }
  823. public static Task<decimal> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector, CancellationToken cancellationToken)
  824. {
  825. if (source == null)
  826. throw Error.ArgumentNull(nameof(source));
  827. if (selector == null)
  828. throw Error.ArgumentNull(nameof(selector));
  829. return MinCore(source, selector, cancellationToken);
  830. }
  831. public static Task<decimal> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal>> selector)
  832. {
  833. if (source == null)
  834. throw Error.ArgumentNull(nameof(source));
  835. if (selector == null)
  836. throw Error.ArgumentNull(nameof(selector));
  837. return MinCore(source, selector, CancellationToken.None);
  838. }
  839. public static Task<decimal> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal>> selector, CancellationToken cancellationToken)
  840. {
  841. if (source == null)
  842. throw Error.ArgumentNull(nameof(source));
  843. if (selector == null)
  844. throw Error.ArgumentNull(nameof(selector));
  845. return MinCore(source, selector, cancellationToken);
  846. }
  847. public static Task<decimal?> Min(this IAsyncEnumerable<decimal?> source)
  848. {
  849. if (source == null)
  850. throw Error.ArgumentNull(nameof(source));
  851. return MinCore(source, CancellationToken.None);
  852. }
  853. public static Task<decimal?> Min(this IAsyncEnumerable<decimal?> source, CancellationToken cancellationToken)
  854. {
  855. if (source == null)
  856. throw Error.ArgumentNull(nameof(source));
  857. return MinCore(source, cancellationToken);
  858. }
  859. public static Task<decimal?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector)
  860. {
  861. if (source == null)
  862. throw Error.ArgumentNull(nameof(source));
  863. if (selector == null)
  864. throw Error.ArgumentNull(nameof(selector));
  865. return MinCore(source, selector, CancellationToken.None);
  866. }
  867. public static Task<decimal?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector, CancellationToken cancellationToken)
  868. {
  869. if (source == null)
  870. throw Error.ArgumentNull(nameof(source));
  871. if (selector == null)
  872. throw Error.ArgumentNull(nameof(selector));
  873. return MinCore(source, selector, cancellationToken);
  874. }
  875. public static Task<decimal?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal?>> selector)
  876. {
  877. if (source == null)
  878. throw Error.ArgumentNull(nameof(source));
  879. if (selector == null)
  880. throw Error.ArgumentNull(nameof(selector));
  881. return MinCore(source, selector, CancellationToken.None);
  882. }
  883. public static Task<decimal?> Min<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task<decimal?>> selector, CancellationToken cancellationToken)
  884. {
  885. if (source == null)
  886. throw Error.ArgumentNull(nameof(source));
  887. if (selector == null)
  888. throw Error.ArgumentNull(nameof(selector));
  889. return MinCore(source, selector, cancellationToken);
  890. }
  891. }
  892. }