AsyncPattern.Generated.cs 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665
  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.Threading.Tasks;
  5. namespace System.Reactive.Joins
  6. {
  7. public class AsyncPattern<TSource1> : AsyncPattern
  8. {
  9. internal IAsyncObservable<TSource1> Source1 { get; }
  10. internal AsyncPattern(IAsyncObservable<TSource1> source1)
  11. {
  12. Source1 = source1;
  13. }
  14. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TResult> selector)
  15. {
  16. if (selector == null)
  17. throw new ArgumentNullException(nameof(selector));
  18. return new AsyncPlan<TSource1, TResult>(this, selector);
  19. }
  20. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, Task<TResult>> selector)
  21. {
  22. if (selector == null)
  23. throw new ArgumentNullException(nameof(selector));
  24. return new AsyncPlanWithTask<TSource1, TResult>(this, selector);
  25. }
  26. }
  27. public class AsyncPattern<TSource1, TSource2> : AsyncPattern
  28. {
  29. internal IAsyncObservable<TSource1> Source1 { get; }
  30. internal IAsyncObservable<TSource2> Source2 { get; }
  31. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2)
  32. {
  33. Source1 = source1;
  34. Source2 = source2;
  35. }
  36. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TResult> selector)
  37. {
  38. if (selector == null)
  39. throw new ArgumentNullException(nameof(selector));
  40. return new AsyncPlan<TSource1, TSource2, TResult>(this, selector);
  41. }
  42. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, Task<TResult>> selector)
  43. {
  44. if (selector == null)
  45. throw new ArgumentNullException(nameof(selector));
  46. return new AsyncPlanWithTask<TSource1, TSource2, TResult>(this, selector);
  47. }
  48. }
  49. public class AsyncPattern<TSource1, TSource2, TSource3> : AsyncPattern
  50. {
  51. internal IAsyncObservable<TSource1> Source1 { get; }
  52. internal IAsyncObservable<TSource2> Source2 { get; }
  53. internal IAsyncObservable<TSource3> Source3 { get; }
  54. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3)
  55. {
  56. Source1 = source1;
  57. Source2 = source2;
  58. Source3 = source3;
  59. }
  60. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TResult> selector)
  61. {
  62. if (selector == null)
  63. throw new ArgumentNullException(nameof(selector));
  64. return new AsyncPlan<TSource1, TSource2, TSource3, TResult>(this, selector);
  65. }
  66. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, Task<TResult>> selector)
  67. {
  68. if (selector == null)
  69. throw new ArgumentNullException(nameof(selector));
  70. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TResult>(this, selector);
  71. }
  72. }
  73. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4> : AsyncPattern
  74. {
  75. internal IAsyncObservable<TSource1> Source1 { get; }
  76. internal IAsyncObservable<TSource2> Source2 { get; }
  77. internal IAsyncObservable<TSource3> Source3 { get; }
  78. internal IAsyncObservable<TSource4> Source4 { get; }
  79. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4)
  80. {
  81. Source1 = source1;
  82. Source2 = source2;
  83. Source3 = source3;
  84. Source4 = source4;
  85. }
  86. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TResult> selector)
  87. {
  88. if (selector == null)
  89. throw new ArgumentNullException(nameof(selector));
  90. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TResult>(this, selector);
  91. }
  92. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, Task<TResult>> selector)
  93. {
  94. if (selector == null)
  95. throw new ArgumentNullException(nameof(selector));
  96. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TResult>(this, selector);
  97. }
  98. }
  99. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5> : AsyncPattern
  100. {
  101. internal IAsyncObservable<TSource1> Source1 { get; }
  102. internal IAsyncObservable<TSource2> Source2 { get; }
  103. internal IAsyncObservable<TSource3> Source3 { get; }
  104. internal IAsyncObservable<TSource4> Source4 { get; }
  105. internal IAsyncObservable<TSource5> Source5 { get; }
  106. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5)
  107. {
  108. Source1 = source1;
  109. Source2 = source2;
  110. Source3 = source3;
  111. Source4 = source4;
  112. Source5 = source5;
  113. }
  114. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult> selector)
  115. {
  116. if (selector == null)
  117. throw new ArgumentNullException(nameof(selector));
  118. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(this, selector);
  119. }
  120. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, Task<TResult>> selector)
  121. {
  122. if (selector == null)
  123. throw new ArgumentNullException(nameof(selector));
  124. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(this, selector);
  125. }
  126. }
  127. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6> : AsyncPattern
  128. {
  129. internal IAsyncObservable<TSource1> Source1 { get; }
  130. internal IAsyncObservable<TSource2> Source2 { get; }
  131. internal IAsyncObservable<TSource3> Source3 { get; }
  132. internal IAsyncObservable<TSource4> Source4 { get; }
  133. internal IAsyncObservable<TSource5> Source5 { get; }
  134. internal IAsyncObservable<TSource6> Source6 { get; }
  135. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6)
  136. {
  137. Source1 = source1;
  138. Source2 = source2;
  139. Source3 = source3;
  140. Source4 = source4;
  141. Source5 = source5;
  142. Source6 = source6;
  143. }
  144. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult> selector)
  145. {
  146. if (selector == null)
  147. throw new ArgumentNullException(nameof(selector));
  148. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(this, selector);
  149. }
  150. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, Task<TResult>> selector)
  151. {
  152. if (selector == null)
  153. throw new ArgumentNullException(nameof(selector));
  154. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(this, selector);
  155. }
  156. }
  157. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7> : AsyncPattern
  158. {
  159. internal IAsyncObservable<TSource1> Source1 { get; }
  160. internal IAsyncObservable<TSource2> Source2 { get; }
  161. internal IAsyncObservable<TSource3> Source3 { get; }
  162. internal IAsyncObservable<TSource4> Source4 { get; }
  163. internal IAsyncObservable<TSource5> Source5 { get; }
  164. internal IAsyncObservable<TSource6> Source6 { get; }
  165. internal IAsyncObservable<TSource7> Source7 { get; }
  166. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7)
  167. {
  168. Source1 = source1;
  169. Source2 = source2;
  170. Source3 = source3;
  171. Source4 = source4;
  172. Source5 = source5;
  173. Source6 = source6;
  174. Source7 = source7;
  175. }
  176. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult> selector)
  177. {
  178. if (selector == null)
  179. throw new ArgumentNullException(nameof(selector));
  180. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(this, selector);
  181. }
  182. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, Task<TResult>> selector)
  183. {
  184. if (selector == null)
  185. throw new ArgumentNullException(nameof(selector));
  186. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(this, selector);
  187. }
  188. }
  189. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8> : AsyncPattern
  190. {
  191. internal IAsyncObservable<TSource1> Source1 { get; }
  192. internal IAsyncObservable<TSource2> Source2 { get; }
  193. internal IAsyncObservable<TSource3> Source3 { get; }
  194. internal IAsyncObservable<TSource4> Source4 { get; }
  195. internal IAsyncObservable<TSource5> Source5 { get; }
  196. internal IAsyncObservable<TSource6> Source6 { get; }
  197. internal IAsyncObservable<TSource7> Source7 { get; }
  198. internal IAsyncObservable<TSource8> Source8 { get; }
  199. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8)
  200. {
  201. Source1 = source1;
  202. Source2 = source2;
  203. Source3 = source3;
  204. Source4 = source4;
  205. Source5 = source5;
  206. Source6 = source6;
  207. Source7 = source7;
  208. Source8 = source8;
  209. }
  210. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult> selector)
  211. {
  212. if (selector == null)
  213. throw new ArgumentNullException(nameof(selector));
  214. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(this, selector);
  215. }
  216. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, Task<TResult>> selector)
  217. {
  218. if (selector == null)
  219. throw new ArgumentNullException(nameof(selector));
  220. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(this, selector);
  221. }
  222. }
  223. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9> : AsyncPattern
  224. {
  225. internal IAsyncObservable<TSource1> Source1 { get; }
  226. internal IAsyncObservable<TSource2> Source2 { get; }
  227. internal IAsyncObservable<TSource3> Source3 { get; }
  228. internal IAsyncObservable<TSource4> Source4 { get; }
  229. internal IAsyncObservable<TSource5> Source5 { get; }
  230. internal IAsyncObservable<TSource6> Source6 { get; }
  231. internal IAsyncObservable<TSource7> Source7 { get; }
  232. internal IAsyncObservable<TSource8> Source8 { get; }
  233. internal IAsyncObservable<TSource9> Source9 { get; }
  234. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9)
  235. {
  236. Source1 = source1;
  237. Source2 = source2;
  238. Source3 = source3;
  239. Source4 = source4;
  240. Source5 = source5;
  241. Source6 = source6;
  242. Source7 = source7;
  243. Source8 = source8;
  244. Source9 = source9;
  245. }
  246. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult> selector)
  247. {
  248. if (selector == null)
  249. throw new ArgumentNullException(nameof(selector));
  250. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(this, selector);
  251. }
  252. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, Task<TResult>> selector)
  253. {
  254. if (selector == null)
  255. throw new ArgumentNullException(nameof(selector));
  256. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(this, selector);
  257. }
  258. }
  259. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10> : AsyncPattern
  260. {
  261. internal IAsyncObservable<TSource1> Source1 { get; }
  262. internal IAsyncObservable<TSource2> Source2 { get; }
  263. internal IAsyncObservable<TSource3> Source3 { get; }
  264. internal IAsyncObservable<TSource4> Source4 { get; }
  265. internal IAsyncObservable<TSource5> Source5 { get; }
  266. internal IAsyncObservable<TSource6> Source6 { get; }
  267. internal IAsyncObservable<TSource7> Source7 { get; }
  268. internal IAsyncObservable<TSource8> Source8 { get; }
  269. internal IAsyncObservable<TSource9> Source9 { get; }
  270. internal IAsyncObservable<TSource10> Source10 { get; }
  271. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10)
  272. {
  273. Source1 = source1;
  274. Source2 = source2;
  275. Source3 = source3;
  276. Source4 = source4;
  277. Source5 = source5;
  278. Source6 = source6;
  279. Source7 = source7;
  280. Source8 = source8;
  281. Source9 = source9;
  282. Source10 = source10;
  283. }
  284. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult> selector)
  285. {
  286. if (selector == null)
  287. throw new ArgumentNullException(nameof(selector));
  288. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(this, selector);
  289. }
  290. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, Task<TResult>> selector)
  291. {
  292. if (selector == null)
  293. throw new ArgumentNullException(nameof(selector));
  294. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(this, selector);
  295. }
  296. }
  297. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11> : AsyncPattern
  298. {
  299. internal IAsyncObservable<TSource1> Source1 { get; }
  300. internal IAsyncObservable<TSource2> Source2 { get; }
  301. internal IAsyncObservable<TSource3> Source3 { get; }
  302. internal IAsyncObservable<TSource4> Source4 { get; }
  303. internal IAsyncObservable<TSource5> Source5 { get; }
  304. internal IAsyncObservable<TSource6> Source6 { get; }
  305. internal IAsyncObservable<TSource7> Source7 { get; }
  306. internal IAsyncObservable<TSource8> Source8 { get; }
  307. internal IAsyncObservable<TSource9> Source9 { get; }
  308. internal IAsyncObservable<TSource10> Source10 { get; }
  309. internal IAsyncObservable<TSource11> Source11 { get; }
  310. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10, IAsyncObservable<TSource11> source11)
  311. {
  312. Source1 = source1;
  313. Source2 = source2;
  314. Source3 = source3;
  315. Source4 = source4;
  316. Source5 = source5;
  317. Source6 = source6;
  318. Source7 = source7;
  319. Source8 = source8;
  320. Source9 = source9;
  321. Source10 = source10;
  322. Source11 = source11;
  323. }
  324. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult> selector)
  325. {
  326. if (selector == null)
  327. throw new ArgumentNullException(nameof(selector));
  328. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(this, selector);
  329. }
  330. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, Task<TResult>> selector)
  331. {
  332. if (selector == null)
  333. throw new ArgumentNullException(nameof(selector));
  334. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(this, selector);
  335. }
  336. }
  337. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12> : AsyncPattern
  338. {
  339. internal IAsyncObservable<TSource1> Source1 { get; }
  340. internal IAsyncObservable<TSource2> Source2 { get; }
  341. internal IAsyncObservable<TSource3> Source3 { get; }
  342. internal IAsyncObservable<TSource4> Source4 { get; }
  343. internal IAsyncObservable<TSource5> Source5 { get; }
  344. internal IAsyncObservable<TSource6> Source6 { get; }
  345. internal IAsyncObservable<TSource7> Source7 { get; }
  346. internal IAsyncObservable<TSource8> Source8 { get; }
  347. internal IAsyncObservable<TSource9> Source9 { get; }
  348. internal IAsyncObservable<TSource10> Source10 { get; }
  349. internal IAsyncObservable<TSource11> Source11 { get; }
  350. internal IAsyncObservable<TSource12> Source12 { get; }
  351. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10, IAsyncObservable<TSource11> source11, IAsyncObservable<TSource12> source12)
  352. {
  353. Source1 = source1;
  354. Source2 = source2;
  355. Source3 = source3;
  356. Source4 = source4;
  357. Source5 = source5;
  358. Source6 = source6;
  359. Source7 = source7;
  360. Source8 = source8;
  361. Source9 = source9;
  362. Source10 = source10;
  363. Source11 = source11;
  364. Source12 = source12;
  365. }
  366. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult> selector)
  367. {
  368. if (selector == null)
  369. throw new ArgumentNullException(nameof(selector));
  370. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(this, selector);
  371. }
  372. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, Task<TResult>> selector)
  373. {
  374. if (selector == null)
  375. throw new ArgumentNullException(nameof(selector));
  376. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(this, selector);
  377. }
  378. }
  379. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13> : AsyncPattern
  380. {
  381. internal IAsyncObservable<TSource1> Source1 { get; }
  382. internal IAsyncObservable<TSource2> Source2 { get; }
  383. internal IAsyncObservable<TSource3> Source3 { get; }
  384. internal IAsyncObservable<TSource4> Source4 { get; }
  385. internal IAsyncObservable<TSource5> Source5 { get; }
  386. internal IAsyncObservable<TSource6> Source6 { get; }
  387. internal IAsyncObservable<TSource7> Source7 { get; }
  388. internal IAsyncObservable<TSource8> Source8 { get; }
  389. internal IAsyncObservable<TSource9> Source9 { get; }
  390. internal IAsyncObservable<TSource10> Source10 { get; }
  391. internal IAsyncObservable<TSource11> Source11 { get; }
  392. internal IAsyncObservable<TSource12> Source12 { get; }
  393. internal IAsyncObservable<TSource13> Source13 { get; }
  394. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10, IAsyncObservable<TSource11> source11, IAsyncObservable<TSource12> source12, IAsyncObservable<TSource13> source13)
  395. {
  396. Source1 = source1;
  397. Source2 = source2;
  398. Source3 = source3;
  399. Source4 = source4;
  400. Source5 = source5;
  401. Source6 = source6;
  402. Source7 = source7;
  403. Source8 = source8;
  404. Source9 = source9;
  405. Source10 = source10;
  406. Source11 = source11;
  407. Source12 = source12;
  408. Source13 = source13;
  409. }
  410. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult> selector)
  411. {
  412. if (selector == null)
  413. throw new ArgumentNullException(nameof(selector));
  414. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(this, selector);
  415. }
  416. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, Task<TResult>> selector)
  417. {
  418. if (selector == null)
  419. throw new ArgumentNullException(nameof(selector));
  420. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(this, selector);
  421. }
  422. }
  423. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14> : AsyncPattern
  424. {
  425. internal IAsyncObservable<TSource1> Source1 { get; }
  426. internal IAsyncObservable<TSource2> Source2 { get; }
  427. internal IAsyncObservable<TSource3> Source3 { get; }
  428. internal IAsyncObservable<TSource4> Source4 { get; }
  429. internal IAsyncObservable<TSource5> Source5 { get; }
  430. internal IAsyncObservable<TSource6> Source6 { get; }
  431. internal IAsyncObservable<TSource7> Source7 { get; }
  432. internal IAsyncObservable<TSource8> Source8 { get; }
  433. internal IAsyncObservable<TSource9> Source9 { get; }
  434. internal IAsyncObservable<TSource10> Source10 { get; }
  435. internal IAsyncObservable<TSource11> Source11 { get; }
  436. internal IAsyncObservable<TSource12> Source12 { get; }
  437. internal IAsyncObservable<TSource13> Source13 { get; }
  438. internal IAsyncObservable<TSource14> Source14 { get; }
  439. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10, IAsyncObservable<TSource11> source11, IAsyncObservable<TSource12> source12, IAsyncObservable<TSource13> source13, IAsyncObservable<TSource14> source14)
  440. {
  441. Source1 = source1;
  442. Source2 = source2;
  443. Source3 = source3;
  444. Source4 = source4;
  445. Source5 = source5;
  446. Source6 = source6;
  447. Source7 = source7;
  448. Source8 = source8;
  449. Source9 = source9;
  450. Source10 = source10;
  451. Source11 = source11;
  452. Source12 = source12;
  453. Source13 = source13;
  454. Source14 = source14;
  455. }
  456. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult> selector)
  457. {
  458. if (selector == null)
  459. throw new ArgumentNullException(nameof(selector));
  460. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(this, selector);
  461. }
  462. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, Task<TResult>> selector)
  463. {
  464. if (selector == null)
  465. throw new ArgumentNullException(nameof(selector));
  466. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(this, selector);
  467. }
  468. }
  469. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15> : AsyncPattern
  470. {
  471. internal IAsyncObservable<TSource1> Source1 { get; }
  472. internal IAsyncObservable<TSource2> Source2 { get; }
  473. internal IAsyncObservable<TSource3> Source3 { get; }
  474. internal IAsyncObservable<TSource4> Source4 { get; }
  475. internal IAsyncObservable<TSource5> Source5 { get; }
  476. internal IAsyncObservable<TSource6> Source6 { get; }
  477. internal IAsyncObservable<TSource7> Source7 { get; }
  478. internal IAsyncObservable<TSource8> Source8 { get; }
  479. internal IAsyncObservable<TSource9> Source9 { get; }
  480. internal IAsyncObservable<TSource10> Source10 { get; }
  481. internal IAsyncObservable<TSource11> Source11 { get; }
  482. internal IAsyncObservable<TSource12> Source12 { get; }
  483. internal IAsyncObservable<TSource13> Source13 { get; }
  484. internal IAsyncObservable<TSource14> Source14 { get; }
  485. internal IAsyncObservable<TSource15> Source15 { get; }
  486. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10, IAsyncObservable<TSource11> source11, IAsyncObservable<TSource12> source12, IAsyncObservable<TSource13> source13, IAsyncObservable<TSource14> source14, IAsyncObservable<TSource15> source15)
  487. {
  488. Source1 = source1;
  489. Source2 = source2;
  490. Source3 = source3;
  491. Source4 = source4;
  492. Source5 = source5;
  493. Source6 = source6;
  494. Source7 = source7;
  495. Source8 = source8;
  496. Source9 = source9;
  497. Source10 = source10;
  498. Source11 = source11;
  499. Source12 = source12;
  500. Source13 = source13;
  501. Source14 = source14;
  502. Source15 = source15;
  503. }
  504. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult> selector)
  505. {
  506. if (selector == null)
  507. throw new ArgumentNullException(nameof(selector));
  508. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(this, selector);
  509. }
  510. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, Task<TResult>> selector)
  511. {
  512. if (selector == null)
  513. throw new ArgumentNullException(nameof(selector));
  514. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(this, selector);
  515. }
  516. }
  517. public class AsyncPattern<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16> : AsyncPattern
  518. {
  519. internal IAsyncObservable<TSource1> Source1 { get; }
  520. internal IAsyncObservable<TSource2> Source2 { get; }
  521. internal IAsyncObservable<TSource3> Source3 { get; }
  522. internal IAsyncObservable<TSource4> Source4 { get; }
  523. internal IAsyncObservable<TSource5> Source5 { get; }
  524. internal IAsyncObservable<TSource6> Source6 { get; }
  525. internal IAsyncObservable<TSource7> Source7 { get; }
  526. internal IAsyncObservable<TSource8> Source8 { get; }
  527. internal IAsyncObservable<TSource9> Source9 { get; }
  528. internal IAsyncObservable<TSource10> Source10 { get; }
  529. internal IAsyncObservable<TSource11> Source11 { get; }
  530. internal IAsyncObservable<TSource12> Source12 { get; }
  531. internal IAsyncObservable<TSource13> Source13 { get; }
  532. internal IAsyncObservable<TSource14> Source14 { get; }
  533. internal IAsyncObservable<TSource15> Source15 { get; }
  534. internal IAsyncObservable<TSource16> Source16 { get; }
  535. internal AsyncPattern(IAsyncObservable<TSource1> source1, IAsyncObservable<TSource2> source2, IAsyncObservable<TSource3> source3, IAsyncObservable<TSource4> source4, IAsyncObservable<TSource5> source5, IAsyncObservable<TSource6> source6, IAsyncObservable<TSource7> source7, IAsyncObservable<TSource8> source8, IAsyncObservable<TSource9> source9, IAsyncObservable<TSource10> source10, IAsyncObservable<TSource11> source11, IAsyncObservable<TSource12> source12, IAsyncObservable<TSource13> source13, IAsyncObservable<TSource14> source14, IAsyncObservable<TSource15> source15, IAsyncObservable<TSource16> source16)
  536. {
  537. Source1 = source1;
  538. Source2 = source2;
  539. Source3 = source3;
  540. Source4 = source4;
  541. Source5 = source5;
  542. Source6 = source6;
  543. Source7 = source7;
  544. Source8 = source8;
  545. Source9 = source9;
  546. Source10 = source10;
  547. Source11 = source11;
  548. Source12 = source12;
  549. Source13 = source13;
  550. Source14 = source14;
  551. Source15 = source15;
  552. Source16 = source16;
  553. }
  554. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult> selector)
  555. {
  556. if (selector == null)
  557. throw new ArgumentNullException(nameof(selector));
  558. return new AsyncPlan<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(this, selector);
  559. }
  560. public AsyncPlan<TResult> Then<TResult>(Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, Task<TResult>> selector)
  561. {
  562. if (selector == null)
  563. throw new ArgumentNullException(nameof(selector));
  564. return new AsyncPlanWithTask<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(this, selector);
  565. }
  566. }
  567. }