Queryable.cs 125 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822
  1. // Permission is hereby granted, free of charge, to any person obtaining
  2. // a copy of this software and associated documentation files (the
  3. // "Software"), to deal in the Software without restriction, including
  4. // without limitation the rights to use, copy, modify, merge, publish,
  5. // distribute, sublicense, and/or sell copies of the Software, and to
  6. // permit persons to whom the Software is furnished to do so, subject to
  7. // the following conditions:
  8. //
  9. // The above copyright notice and this permission notice shall be
  10. // included in all copies or substantial portions of the Software.
  11. //
  12. // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  13. // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  14. // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  15. // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  16. // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  17. // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  18. //
  19. // Authors:
  20. // Alejandro Serrano "Serras" ([email protected])
  21. // Marek Safar ([email protected])
  22. //
  23. using System;
  24. using System.Collections.Generic;
  25. using System.Linq.Expressions;
  26. namespace System.Linq
  27. {
  28. public static class Queryable
  29. {
  30. #region Count
  31. public static int Count<TSource> (this IQueryable<TSource> source)
  32. {
  33. if (source == null)
  34. throw new ArgumentNullException ();
  35. if (source is ICollection<TSource>)
  36. return ((ICollection<TSource>)source).Count;
  37. int counter = 0;
  38. foreach (TSource element in source)
  39. counter++;
  40. return counter;
  41. }
  42. public static int Count<TSource> (
  43. this IQueryable<TSource> source,
  44. Func<TSource, bool> selector)
  45. {
  46. if (source == null || selector == null)
  47. throw new ArgumentNullException ();
  48. int counter = 0;
  49. foreach (TSource element in source)
  50. if (selector(element))
  51. counter++;
  52. return counter;
  53. }
  54. #endregion
  55. #region LongCount
  56. public static long LongCount<TSource> (this IQueryable<TSource> source)
  57. {
  58. if (source == null)
  59. throw new ArgumentNullException ();
  60. long counter = 0;
  61. foreach (TSource element in source)
  62. counter++;
  63. return counter;
  64. }
  65. public static long LongCount<TSource> (
  66. this IQueryable<TSource> source,
  67. Func<TSource, bool> selector)
  68. {
  69. if (source == null || selector == null)
  70. throw new ArgumentNullException ();
  71. long counter = 0;
  72. foreach (TSource element in source)
  73. if (selector(element))
  74. counter++;
  75. return counter;
  76. }
  77. #endregion
  78. #region Sum
  79. public static int Sum (this IQueryable<int> source)
  80. {
  81. if (source == null)
  82. throw new ArgumentNullException ();
  83. int sum = 0;
  84. foreach (int element in source)
  85. sum += element;
  86. return sum;
  87. }
  88. public static int Sum<TSource> (
  89. this IQueryable<TSource> source,
  90. Func<TSource, int> selector)
  91. {
  92. if (source == null || selector == null)
  93. throw new ArgumentNullException ();
  94. int sum = 0;
  95. foreach (TSource element in source)
  96. sum += selector (element);
  97. return sum;
  98. }
  99. public static int? Sum (this IQueryable<int?> source)
  100. {
  101. if (source == null)
  102. throw new ArgumentNullException ();
  103. int? sum = 0;
  104. foreach (int? element in source)
  105. if (element.HasValue)
  106. sum += element.Value;
  107. return sum;
  108. }
  109. public static int? Sum<TSource> (
  110. this IQueryable<TSource> source,
  111. Func<TSource, int?> selector)
  112. {
  113. if (source == null || selector == null)
  114. throw new ArgumentNullException ();
  115. int? sum = 0;
  116. foreach (TSource element in source) {
  117. int? item = selector (element);
  118. if (item.HasValue)
  119. sum += item.Value;
  120. }
  121. return sum;
  122. }
  123. public static long Sum (this IQueryable<long> source)
  124. {
  125. if (source == null)
  126. throw new ArgumentNullException ();
  127. long sum = 0;
  128. foreach (long element in source)
  129. sum += element;
  130. return sum;
  131. }
  132. public static long Sum<TSource> (
  133. this IQueryable<TSource> source,
  134. Func<TSource, long> selector)
  135. {
  136. if (source == null || selector == null)
  137. throw new ArgumentNullException ();
  138. long sum = 0;
  139. foreach (TSource element in source)
  140. sum += selector (element);
  141. return sum;
  142. }
  143. public static long? Sum (this IQueryable<long?> source)
  144. {
  145. if (source == null)
  146. throw new ArgumentNullException ();
  147. long? sum = 0;
  148. foreach (long? element in source)
  149. if (element.HasValue)
  150. sum += element.Value;
  151. return sum;
  152. }
  153. public static long? Sum<TSource> (
  154. this IQueryable<TSource> source,
  155. Func<TSource, long?> selector)
  156. {
  157. if (source == null || selector == null)
  158. throw new ArgumentNullException ();
  159. long? sum = 0;
  160. foreach (TSource element in source) {
  161. long? item = selector (element);
  162. if (item.HasValue)
  163. sum += item.Value;
  164. }
  165. return sum;
  166. }
  167. public static double Sum (this IQueryable<double> source)
  168. {
  169. if (source == null)
  170. throw new ArgumentNullException ();
  171. double sum = 0;
  172. foreach (double element in source)
  173. sum += element;
  174. return sum;
  175. }
  176. public static double Sum<TSource> (
  177. this IQueryable<TSource> source,
  178. Func<TSource, double> selector)
  179. {
  180. if (source == null || selector == null)
  181. throw new ArgumentNullException ();
  182. double sum = 0;
  183. foreach (TSource element in source)
  184. sum += selector (element);
  185. return sum;
  186. }
  187. public static double? Sum (this IQueryable<double?> source)
  188. {
  189. if (source == null)
  190. throw new ArgumentNullException ();
  191. double? sum = 0;
  192. foreach (double? element in source)
  193. if (element.HasValue)
  194. sum += element.Value;
  195. return sum;
  196. }
  197. public static double? Sum<TSource> (
  198. this IQueryable<TSource> source,
  199. Func<TSource, double?> selector)
  200. {
  201. if (source == null || selector == null)
  202. throw new ArgumentNullException ();
  203. double? sum = 0;
  204. foreach (TSource element in source) {
  205. double? item = selector (element);
  206. if (item.HasValue)
  207. sum += item.Value;
  208. }
  209. return sum;
  210. }
  211. public static decimal Sum (this IQueryable<decimal> source)
  212. {
  213. if (source == null)
  214. throw new ArgumentNullException ();
  215. decimal sum = 0;
  216. foreach (decimal element in source)
  217. sum += element;
  218. return sum;
  219. }
  220. public static decimal Sum<TSource> (
  221. this IQueryable<TSource> source,
  222. Func<TSource, decimal> selector)
  223. {
  224. if (source == null || selector == null)
  225. throw new ArgumentNullException ();
  226. decimal sum = 0;
  227. foreach (TSource element in source)
  228. sum += selector (element);
  229. return sum;
  230. }
  231. public static decimal? Sum (this IQueryable<decimal?> source)
  232. {
  233. if (source == null)
  234. throw new ArgumentNullException ();
  235. decimal? sum = 0;
  236. foreach (decimal? element in source)
  237. if (element.HasValue)
  238. sum += element.Value;
  239. return sum;
  240. }
  241. public static decimal? Sum<TSource> (
  242. this IQueryable<TSource> source,
  243. Func<TSource, decimal?> selector)
  244. {
  245. if (source == null || selector == null)
  246. throw new ArgumentNullException ();
  247. decimal? sum = 0;
  248. foreach (TSource element in source) {
  249. decimal? item = selector (element);
  250. if (item.HasValue)
  251. sum += item.Value;
  252. }
  253. return sum;
  254. }
  255. #endregion
  256. #region Min
  257. public static int Min (this IQueryable<int> source)
  258. {
  259. if (source == null)
  260. throw new ArgumentNullException ();
  261. int minimum = int.MaxValue;
  262. int counter = 0;
  263. foreach (int element in source) {
  264. if (element < minimum)
  265. minimum = element;
  266. counter++;
  267. }
  268. if (counter == 0)
  269. throw new InvalidOperationException ();
  270. else
  271. return minimum;
  272. }
  273. public static int? Min (this IQueryable<int?> source)
  274. {
  275. if (source == null)
  276. throw new ArgumentNullException ();
  277. bool onlyNull = true;
  278. int? minimum = int.MaxValue;
  279. foreach (int? element in source) {
  280. if (element.HasValue) {
  281. onlyNull = false;
  282. if (element < minimum)
  283. minimum = element;
  284. }
  285. }
  286. return (onlyNull ? null : minimum);
  287. }
  288. public static long Min (this IQueryable<long> source)
  289. {
  290. if (source == null)
  291. throw new ArgumentNullException ();
  292. long minimum = long.MaxValue;
  293. int counter = 0;
  294. foreach (long element in source) {
  295. if (element < minimum)
  296. minimum = element;
  297. counter++;
  298. }
  299. if (counter == 0)
  300. throw new InvalidOperationException ();
  301. else
  302. return minimum;
  303. }
  304. public static long? Min (this IQueryable<long?> source)
  305. {
  306. if (source == null)
  307. throw new ArgumentNullException ();
  308. bool onlyNull = true;
  309. long? minimum = long.MaxValue;
  310. foreach (long? element in source) {
  311. if (element.HasValue) {
  312. onlyNull = false;
  313. if (element < minimum)
  314. minimum = element;
  315. }
  316. }
  317. return (onlyNull ? null : minimum);
  318. }
  319. public static double Min (this IQueryable<double> source)
  320. {
  321. if (source == null)
  322. throw new ArgumentNullException ();
  323. double minimum = double.MaxValue;
  324. int counter = 0;
  325. foreach (double element in source) {
  326. if (element < minimum)
  327. minimum = element;
  328. counter++;
  329. }
  330. if (counter == 0)
  331. throw new InvalidOperationException ();
  332. else
  333. return minimum;
  334. }
  335. public static double? Min (this IQueryable<double?> source)
  336. {
  337. if (source == null)
  338. throw new ArgumentNullException ();
  339. bool onlyNull = true;
  340. double? minimum = double.MaxValue;
  341. foreach (double? element in source) {
  342. if (element.HasValue) {
  343. onlyNull = false;
  344. if (element < minimum)
  345. minimum = element;
  346. }
  347. }
  348. return (onlyNull ? null : minimum);
  349. }
  350. public static decimal Min (this IQueryable<decimal> source)
  351. {
  352. if (source == null)
  353. throw new ArgumentNullException ();
  354. decimal minimum = decimal.MaxValue;
  355. int counter = 0;
  356. foreach (decimal element in source) {
  357. if (element < minimum)
  358. minimum = element;
  359. counter++;
  360. }
  361. if (counter == 0)
  362. throw new InvalidOperationException ();
  363. else
  364. return minimum;
  365. }
  366. public static decimal? Min (this IQueryable<decimal?> source)
  367. {
  368. if (source == null)
  369. throw new ArgumentNullException ();
  370. bool onlyNull = true;
  371. decimal? minimum = decimal.MaxValue;
  372. foreach (decimal? element in source) {
  373. if (element.HasValue) {
  374. onlyNull = false;
  375. if (element < minimum)
  376. minimum = element;
  377. }
  378. }
  379. return (onlyNull ? null : minimum);
  380. }
  381. public static TSource Min<TSource> (this IQueryable<TSource> source)
  382. {
  383. if (source == null)
  384. throw new ArgumentNullException ();
  385. bool notAssigned = true;
  386. TSource minimum = default (TSource);
  387. int counter = 0;
  388. foreach (TSource element in source) {
  389. if (notAssigned) {
  390. minimum = element;
  391. notAssigned = false;
  392. }
  393. else {
  394. int comparison;
  395. if (element is IComparable<TSource>)
  396. comparison = ((IComparable<TSource>)element).CompareTo (minimum);
  397. else if (element is System.IComparable)
  398. comparison = ((System.IComparable)element).CompareTo (minimum);
  399. else
  400. throw new ArgumentNullException();
  401. if (comparison < 0)
  402. minimum = element;
  403. }
  404. counter++;
  405. }
  406. if (counter == 0)
  407. throw new InvalidOperationException ();
  408. else
  409. return minimum;
  410. }
  411. public static int Min<TSource> (
  412. this IQueryable<TSource> source,
  413. Func<TSource, int> selector)
  414. {
  415. if (source == null || selector == null)
  416. throw new ArgumentNullException ();
  417. int minimum = int.MaxValue;
  418. int counter = 0;
  419. foreach (TSource item in source) {
  420. int element = selector (item);
  421. if (element < minimum)
  422. minimum = element;
  423. counter++;
  424. }
  425. if (counter == 0)
  426. throw new InvalidOperationException ();
  427. else
  428. return minimum;
  429. }
  430. public static int? Min<TSource> (
  431. this IQueryable<TSource> source,
  432. Func<TSource, int?> selector)
  433. {
  434. if (source == null || selector == null)
  435. throw new ArgumentNullException ();
  436. bool onlyNull = true;
  437. int? minimum = int.MaxValue;
  438. foreach (TSource item in source) {
  439. int? element = selector (item);
  440. if (element.HasValue) {
  441. onlyNull = false;
  442. if (element < minimum)
  443. minimum = element;
  444. }
  445. }
  446. return (onlyNull ? null : minimum);
  447. }
  448. public static long Min<TSource> (
  449. this IQueryable<TSource> source,
  450. Func<TSource, long> selector)
  451. {
  452. if (source == null || selector == null)
  453. throw new ArgumentNullException ();
  454. long minimum = long.MaxValue;
  455. int counter = 0;
  456. foreach (TSource item in source) {
  457. long element = selector (item);
  458. if (element < minimum)
  459. minimum = element;
  460. counter++;
  461. }
  462. if (counter == 0)
  463. throw new InvalidOperationException ();
  464. else
  465. return minimum;
  466. }
  467. public static long? Min<TSource> (
  468. this IQueryable<TSource> source,
  469. Func<TSource, long?> selector)
  470. {
  471. if (source == null || selector == null)
  472. throw new ArgumentNullException ();
  473. bool onlyNull = true;
  474. long? minimum = long.MaxValue;
  475. foreach (TSource item in source) {
  476. long? element = selector (item);
  477. if (element.HasValue) {
  478. onlyNull = false;
  479. if (element < minimum)
  480. minimum = element;
  481. }
  482. }
  483. return (onlyNull ? null : minimum);
  484. }
  485. public static double Min<TSource> (
  486. this IQueryable<TSource> source,
  487. Func<TSource, double> selector)
  488. {
  489. if (source == null || selector == null)
  490. throw new ArgumentNullException ();
  491. double minimum = double.MaxValue;
  492. int counter = 0;
  493. foreach (TSource item in source)
  494. {
  495. double element = selector (item);
  496. if (element < minimum)
  497. minimum = element;
  498. counter++;
  499. }
  500. if (counter == 0)
  501. throw new InvalidOperationException ();
  502. else
  503. return minimum;
  504. }
  505. public static double? Min<TSource> (
  506. this IQueryable<TSource> source,
  507. Func<TSource, double?> selector)
  508. {
  509. if (source == null || selector == null)
  510. throw new ArgumentNullException ();
  511. bool onlyNull = true;
  512. double? minimum = double.MaxValue;
  513. foreach (TSource item in source) {
  514. double? element = selector (item);
  515. if (element.HasValue) {
  516. onlyNull = false;
  517. if (element < minimum)
  518. minimum = element;
  519. }
  520. }
  521. return (onlyNull ? null : minimum);
  522. }
  523. public static decimal Min<TSource> (
  524. this IQueryable<TSource> source,
  525. Func<TSource, decimal> selector)
  526. {
  527. if (source == null || selector == null)
  528. throw new ArgumentNullException ();
  529. decimal minimum = decimal.MaxValue;
  530. int counter = 0;
  531. foreach (TSource item in source) {
  532. decimal element = selector (item);
  533. if (element < minimum)
  534. minimum = element;
  535. counter++;
  536. }
  537. if (counter == 0)
  538. throw new InvalidOperationException ();
  539. else
  540. return minimum;
  541. }
  542. public static decimal? Min<TSource> (
  543. this IQueryable<TSource> source,
  544. Func<TSource, decimal?> selector)
  545. {
  546. if (source == null || selector == null)
  547. throw new ArgumentNullException ();
  548. bool onlyNull = true;
  549. decimal? minimum = decimal.MaxValue;
  550. foreach (TSource item in source) {
  551. decimal? element = selector (item);
  552. if (element.HasValue) {
  553. onlyNull = false;
  554. if (element < minimum)
  555. minimum = element;
  556. }
  557. }
  558. return (onlyNull ? null : minimum);
  559. }
  560. public static TResult Min<TSource, TResult> (
  561. this IQueryable<TSource> source,
  562. Func<TSource, TResult> selector)
  563. {
  564. if (source == null || selector == null)
  565. throw new ArgumentNullException ();
  566. bool notAssigned = true;
  567. TResult minimum = default (TResult);
  568. int counter = 0;
  569. foreach (TSource item in source) {
  570. TResult element = selector (item);
  571. if (notAssigned) {
  572. minimum = element;
  573. notAssigned = false;
  574. }
  575. else {
  576. int comparison;
  577. if (element is IComparable<TResult>)
  578. comparison = ((IComparable<TResult>)element).CompareTo (minimum);
  579. else if (element is System.IComparable)
  580. comparison = ((System.IComparable)element).CompareTo (minimum);
  581. else
  582. throw new ArgumentNullException ();
  583. if (comparison < 0)
  584. minimum = element;
  585. }
  586. counter++;
  587. }
  588. if (counter == 0)
  589. throw new InvalidOperationException ();
  590. else
  591. return minimum;
  592. }
  593. #endregion
  594. #region Max
  595. public static int Max (this IQueryable<int> source)
  596. {
  597. if (source == null)
  598. throw new ArgumentNullException ();
  599. int maximum = int.MinValue;
  600. int counter = 0;
  601. foreach (int element in source) {
  602. if (element > maximum)
  603. maximum = element;
  604. counter++;
  605. }
  606. if (counter == 0)
  607. throw new InvalidOperationException ();
  608. else
  609. return maximum;
  610. }
  611. public static int? Max (this IQueryable<int?> source)
  612. {
  613. if (source == null)
  614. throw new ArgumentNullException ();
  615. bool onlyNull = true;
  616. int? maximum = int.MinValue;
  617. foreach (int? element in source) {
  618. if (element.HasValue) {
  619. onlyNull = false;
  620. if (element > maximum)
  621. maximum = element;
  622. }
  623. }
  624. return (onlyNull ? null : maximum);
  625. }
  626. public static long Max (this IQueryable<long> source)
  627. {
  628. if (source == null)
  629. throw new ArgumentNullException ();
  630. long maximum = long.MinValue;
  631. int counter = 0;
  632. foreach (long element in source) {
  633. if (element > maximum)
  634. maximum = element;
  635. counter++;
  636. }
  637. if (counter == 0)
  638. throw new InvalidOperationException ();
  639. else
  640. return maximum;
  641. }
  642. public static long? Max (this IQueryable<long?> source)
  643. {
  644. if (source == null)
  645. throw new ArgumentNullException ();
  646. bool onlyNull = true;
  647. long? maximum = long.MinValue;
  648. foreach (long? element in source) {
  649. if (element.HasValue) {
  650. onlyNull = false;
  651. if (element > maximum)
  652. maximum = element;
  653. }
  654. }
  655. return (onlyNull ? null : maximum);
  656. }
  657. public static double Max (
  658. this IQueryable<double> source)
  659. {
  660. if (source == null)
  661. throw new ArgumentNullException ();
  662. double maximum = double.MinValue;
  663. int counter = 0;
  664. foreach (double element in source) {
  665. if (element > maximum)
  666. maximum = element;
  667. counter++;
  668. }
  669. if (counter == 0)
  670. throw new InvalidOperationException ();
  671. else
  672. return maximum;
  673. }
  674. public static double? Max (
  675. this IQueryable<double?> source)
  676. {
  677. if (source == null)
  678. throw new ArgumentNullException ();
  679. bool onlyNull = true;
  680. double? maximum = double.MinValue;
  681. foreach (double? element in source) {
  682. if (element.HasValue) {
  683. onlyNull = false;
  684. if (element > maximum)
  685. maximum = element;
  686. }
  687. }
  688. return (onlyNull ? null : maximum);
  689. }
  690. public static decimal Max (
  691. this IQueryable<decimal> source)
  692. {
  693. if (source == null)
  694. throw new ArgumentNullException ();
  695. decimal maximum = decimal.MinValue;
  696. int counter = 0;
  697. foreach (decimal element in source) {
  698. if (element > maximum)
  699. maximum = element;
  700. counter++;
  701. }
  702. if (counter == 0)
  703. throw new InvalidOperationException ();
  704. else
  705. return maximum;
  706. }
  707. public static decimal? Max (
  708. this IQueryable<decimal?> source)
  709. {
  710. if (source == null)
  711. throw new ArgumentNullException ();
  712. bool onlyNull = true;
  713. decimal? maximum = decimal.MinValue;
  714. foreach (decimal? element in source) {
  715. if (element.HasValue) {
  716. onlyNull = false;
  717. if (element > maximum)
  718. maximum = element;
  719. }
  720. }
  721. return (onlyNull ? null : maximum);
  722. }
  723. public static TSource Max<TSource> (
  724. this IQueryable<TSource> source)
  725. {
  726. if (source == null)
  727. throw new ArgumentNullException ();
  728. bool notAssigned = true;
  729. TSource maximum = default (TSource);
  730. int counter = 0;
  731. foreach (TSource element in source) {
  732. if (notAssigned) {
  733. maximum = element;
  734. notAssigned = false;
  735. }
  736. else {
  737. int comparison;
  738. if (element is IComparable<TSource>)
  739. comparison = ((IComparable<TSource>)element).CompareTo (maximum);
  740. else if (element is System.IComparable)
  741. comparison = ((System.IComparable)element).CompareTo (maximum);
  742. else
  743. throw new ArgumentNullException();
  744. if (comparison > 0)
  745. maximum = element;
  746. }
  747. counter++;
  748. }
  749. if (counter == 0)
  750. throw new InvalidOperationException ();
  751. else
  752. return maximum;
  753. }
  754. public static int Max<TSource> (
  755. this IQueryable<TSource> source,
  756. Func<TSource, int> selector)
  757. {
  758. if (source == null || selector == null)
  759. throw new ArgumentNullException ();
  760. int maximum = int.MinValue;
  761. int counter = 0;
  762. foreach (TSource item in source)
  763. {
  764. int element = selector (item);
  765. if (element > maximum)
  766. maximum = element;
  767. counter++;
  768. }
  769. if (counter == 0)
  770. throw new InvalidOperationException ();
  771. else
  772. return maximum;
  773. }
  774. public static int? Max<TSource> (
  775. this IQueryable<TSource> source,
  776. Func<TSource, int?> selector)
  777. {
  778. if (source == null || selector == null)
  779. throw new ArgumentNullException ();
  780. bool onlyNull = true;
  781. int? maximum = int.MinValue;
  782. foreach (TSource item in source) {
  783. int? element = selector (item);
  784. if (element.HasValue) {
  785. onlyNull = false;
  786. if (element > maximum)
  787. maximum = element;
  788. }
  789. }
  790. return (onlyNull ? null : maximum);
  791. }
  792. public static long Max<TSource> (
  793. this IQueryable<TSource> source,
  794. Func<TSource, long> selector)
  795. {
  796. if (source == null || selector == null)
  797. throw new ArgumentNullException ();
  798. long maximum = long.MinValue;
  799. int counter = 0;
  800. foreach (TSource item in source) {
  801. long element = selector (item);
  802. if (element > maximum)
  803. maximum = element;
  804. counter++;
  805. }
  806. if (counter == 0)
  807. throw new InvalidOperationException ();
  808. else
  809. return maximum;
  810. }
  811. public static long? Max<TSource> (
  812. this IQueryable<TSource> source,
  813. Func<TSource, long?> selector)
  814. {
  815. if (source == null || selector == null)
  816. throw new ArgumentNullException ();
  817. bool onlyNull = true;
  818. long? maximum = long.MinValue;
  819. foreach (TSource item in source) {
  820. long? element = selector (item);
  821. if (element.HasValue) {
  822. onlyNull = false;
  823. if (element > maximum)
  824. maximum = element;
  825. }
  826. }
  827. return (onlyNull ? null : maximum);
  828. }
  829. public static double Max<TSource> (
  830. this IQueryable<TSource> source,
  831. Func<TSource, double> selector)
  832. {
  833. if (source == null || selector == null)
  834. throw new ArgumentNullException ();
  835. double maximum = double.MinValue;
  836. int counter = 0;
  837. foreach (TSource item in source) {
  838. double element = selector (item);
  839. if (element > maximum)
  840. maximum = element;
  841. counter++;
  842. }
  843. if (counter == 0)
  844. throw new InvalidOperationException ();
  845. else
  846. return maximum;
  847. }
  848. public static double? Max<TSource> (
  849. this IQueryable<TSource> source,
  850. Func<TSource, double?> selector)
  851. {
  852. if (source == null || selector == null)
  853. throw new ArgumentNullException ();
  854. bool onlyNull = true;
  855. double? maximum = double.MinValue;
  856. foreach (TSource item in source) {
  857. double? element = selector(item);
  858. if (element.HasValue) {
  859. onlyNull = false;
  860. if (element > maximum)
  861. maximum = element;
  862. }
  863. }
  864. return (onlyNull ? null : maximum);
  865. }
  866. public static decimal Max<TSource> (
  867. this IQueryable<TSource> source,
  868. Func<TSource, decimal> selector)
  869. {
  870. if (source == null || selector == null)
  871. throw new ArgumentNullException ();
  872. decimal maximum = decimal.MinValue;
  873. int counter = 0;
  874. foreach (TSource item in source) {
  875. decimal element = selector(item);
  876. if (element > maximum)
  877. maximum = element;
  878. counter++;
  879. }
  880. if (counter == 0)
  881. throw new InvalidOperationException ();
  882. else
  883. return maximum;
  884. }
  885. public static decimal? Max<TSource> (
  886. this IQueryable<TSource> source,
  887. Func<TSource, decimal?> selector)
  888. {
  889. if (source == null || selector == null)
  890. throw new ArgumentNullException ();
  891. bool onlyNull = true;
  892. decimal? maximum = decimal.MinValue;
  893. foreach (TSource item in source) {
  894. decimal? element = selector(item);
  895. if (element.HasValue) {
  896. onlyNull = false;
  897. if (element > maximum)
  898. maximum = element;
  899. }
  900. }
  901. return (onlyNull ? null : maximum);
  902. }
  903. public static TResult Max<TSource, TResult> (
  904. this IQueryable<TSource> source,
  905. Func<TSource, TResult> selector)
  906. {
  907. if (source == null || selector == null)
  908. throw new ArgumentNullException ();
  909. bool notAssigned = true;
  910. TResult maximum = default (TResult);
  911. int counter = 0;
  912. foreach (TSource item in source)
  913. {
  914. TResult element = selector (item);
  915. if (notAssigned) {
  916. maximum = element;
  917. notAssigned = false;
  918. }
  919. else {
  920. int comparison;
  921. if (element is IComparable<TResult>)
  922. comparison = ((IComparable<TResult>)element).CompareTo (maximum);
  923. else if (element is System.IComparable)
  924. comparison = ((System.IComparable)element).CompareTo (maximum);
  925. else
  926. throw new ArgumentNullException();
  927. if (comparison > 0)
  928. maximum = element;
  929. }
  930. counter++;
  931. }
  932. if (counter == 0)
  933. throw new InvalidOperationException ();
  934. else
  935. return maximum;
  936. }
  937. #endregion
  938. #region Average
  939. public static double Average (this IQueryable<int> source)
  940. {
  941. if (source == null)
  942. throw new ArgumentNullException ();
  943. long sum = 0;
  944. long counter = 0;
  945. foreach (int element in source) {
  946. sum += element;
  947. counter++;
  948. }
  949. if (counter == 0)
  950. throw new InvalidOperationException ();
  951. else
  952. return (double)sum / (double)counter;
  953. }
  954. public static double? Average (this IQueryable<int?> source)
  955. {
  956. if (source == null)
  957. throw new ArgumentNullException ();
  958. bool onlyNull = true;
  959. long sum = 0;
  960. long counter = 0;
  961. foreach (int? element in source) {
  962. if (element.HasValue) {
  963. onlyNull = false;
  964. sum += element.Value;
  965. counter++;
  966. }
  967. }
  968. return (onlyNull ? null : (double?)sum / (double?)counter);
  969. }
  970. public static double Average (this IQueryable<long> source)
  971. {
  972. if (source == null)
  973. throw new ArgumentNullException ();
  974. long sum = 0;
  975. long counter = 0;
  976. foreach (long element in source) {
  977. sum += element;
  978. counter++;
  979. }
  980. if (counter == 0)
  981. throw new InvalidOperationException ();
  982. else
  983. return (double)sum / (double)counter;
  984. }
  985. public static double? Average (this IQueryable<long?> source)
  986. {
  987. if (source == null)
  988. throw new ArgumentNullException ();
  989. bool onlyNull = true;
  990. long sum = 0;
  991. long counter = 0;
  992. foreach (long? element in source) {
  993. if (element.HasValue) {
  994. onlyNull = false;
  995. sum += element.Value;
  996. counter++;
  997. }
  998. }
  999. return (onlyNull ? null : (double?)sum / (double?)counter);
  1000. }
  1001. public static double Average (this IQueryable<double> source)
  1002. {
  1003. if (source == null)
  1004. throw new ArgumentNullException ();
  1005. double sum = 0;
  1006. double counter = 0;
  1007. foreach (double element in source) {
  1008. sum += element;
  1009. counter++;
  1010. }
  1011. if (counter == 0)
  1012. throw new InvalidOperationException ();
  1013. else
  1014. return sum / counter;
  1015. }
  1016. public static double? Average (this IQueryable<double?> source)
  1017. {
  1018. if (source == null)
  1019. throw new ArgumentNullException ();
  1020. bool onlyNull = true;
  1021. double sum = 0;
  1022. double counter = 0;
  1023. foreach (double? element in source) {
  1024. if (element.HasValue) {
  1025. onlyNull = false;
  1026. sum += element.Value;
  1027. counter++;
  1028. }
  1029. }
  1030. return (onlyNull ? null : (double?)(sum / counter));
  1031. }
  1032. public static decimal Average (this IQueryable<decimal> source)
  1033. {
  1034. if (source == null)
  1035. throw new ArgumentNullException ();
  1036. decimal sum = 0;
  1037. decimal counter = 0;
  1038. foreach (decimal element in source) {
  1039. sum += element;
  1040. counter++;
  1041. }
  1042. if (counter == 0)
  1043. throw new InvalidOperationException ();
  1044. else
  1045. return sum / counter;
  1046. }
  1047. public static decimal? Average (this IQueryable<decimal?> source)
  1048. {
  1049. if (source == null)
  1050. throw new ArgumentNullException ();
  1051. bool onlyNull = true;
  1052. decimal sum = 0;
  1053. decimal counter = 0;
  1054. foreach (decimal? element in source) {
  1055. if (element.HasValue) {
  1056. onlyNull = false;
  1057. sum += element.Value;
  1058. counter++;
  1059. }
  1060. }
  1061. return (onlyNull ? null : (decimal?)(sum / counter));
  1062. }
  1063. public static double Average<TSource> (this IQueryable<TSource> source,
  1064. Func<TSource, int> selector)
  1065. {
  1066. if (source == null || selector == null)
  1067. throw new ArgumentNullException ();
  1068. long sum = 0;
  1069. long counter = 0;
  1070. foreach (TSource item in source) {
  1071. sum += selector (item);
  1072. counter++;
  1073. }
  1074. if (counter == 0)
  1075. throw new InvalidOperationException ();
  1076. else
  1077. return (double)sum / (double)counter;
  1078. }
  1079. public static double? Average<TSource> (this IQueryable<TSource> source,
  1080. Func<TSource, int?> selector)
  1081. {
  1082. if (source == null || selector == null)
  1083. throw new ArgumentNullException ();
  1084. bool onlyNull = true;
  1085. long sum = 0;
  1086. long counter = 0;
  1087. foreach (TSource item in source) {
  1088. int? element = selector (item);
  1089. if (element.HasValue) {
  1090. onlyNull = false;
  1091. sum += element.Value;
  1092. counter++;
  1093. }
  1094. }
  1095. return (onlyNull ? null : (double?)sum / (double?)counter);
  1096. }
  1097. public static double Average<TSource> (this IQueryable<TSource> source,
  1098. Func<TSource, long> selector)
  1099. {
  1100. if (source == null || selector == null)
  1101. throw new ArgumentNullException ();
  1102. long sum = 0;
  1103. long counter = 0;
  1104. foreach (TSource item in source) {
  1105. sum += selector (item);
  1106. counter++;
  1107. }
  1108. if (counter == 0)
  1109. throw new InvalidOperationException();
  1110. else
  1111. return (double)sum / (double)counter;
  1112. }
  1113. public static double? Average<TSource> (this IQueryable<TSource> source,
  1114. Func<TSource, long?> selector)
  1115. {
  1116. if (source == null || selector == null)
  1117. throw new ArgumentNullException ();
  1118. bool onlyNull = true;
  1119. long sum = 0;
  1120. long counter = 0;
  1121. foreach (TSource item in source) {
  1122. long? element = selector (item);
  1123. if (element.HasValue) {
  1124. onlyNull = false;
  1125. sum += element.Value;
  1126. counter++;
  1127. }
  1128. }
  1129. return (onlyNull ? null : (double?)sum/(double?)counter);
  1130. }
  1131. public static double Average<TSource> (this IQueryable<TSource> source,
  1132. Func<TSource, double> selector)
  1133. {
  1134. if (source == null || selector == null)
  1135. throw new ArgumentNullException ();
  1136. double sum = 0;
  1137. double counter = 0;
  1138. foreach (TSource item in source) {
  1139. sum += selector (item);
  1140. counter++;
  1141. }
  1142. if (counter == 0)
  1143. throw new InvalidOperationException ();
  1144. else
  1145. return sum / counter;
  1146. }
  1147. public static double? Average<TSource> (this IQueryable<TSource> source,
  1148. Func<TSource, double?> selector)
  1149. {
  1150. if (source == null || selector == null)
  1151. throw new ArgumentNullException ();
  1152. bool onlyNull = true;
  1153. double sum = 0;
  1154. double counter = 0;
  1155. foreach (TSource item in source) {
  1156. double? element = selector (item);
  1157. if (element.HasValue) {
  1158. onlyNull = false;
  1159. sum += element.Value;
  1160. counter++;
  1161. }
  1162. }
  1163. return (onlyNull ? null : (double?)(sum/counter));
  1164. }
  1165. public static decimal Average<TSource> (this IQueryable<TSource> source,
  1166. Func<TSource, decimal> selector)
  1167. {
  1168. if (source == null || selector == null)
  1169. throw new ArgumentNullException ();
  1170. decimal sum = 0;
  1171. decimal counter = 0;
  1172. foreach (TSource item in source) {
  1173. sum += selector(item);
  1174. counter++;
  1175. }
  1176. if (counter == 0)
  1177. throw new InvalidOperationException ();
  1178. else
  1179. return sum / counter;
  1180. }
  1181. public static decimal? Average<TSource> (this IQueryable<TSource> source,
  1182. Func<TSource, decimal?> selector)
  1183. {
  1184. if (source == null || selector == null)
  1185. throw new ArgumentNullException ();
  1186. bool onlyNull = true;
  1187. decimal sum = 0;
  1188. decimal counter = 0;
  1189. foreach (TSource item in source) {
  1190. decimal? element = selector (item);
  1191. if (element.HasValue) {
  1192. onlyNull = false;
  1193. sum += element.Value;
  1194. counter++;
  1195. }
  1196. }
  1197. return (onlyNull ? null : (decimal?)(sum/counter));
  1198. }
  1199. #endregion
  1200. #region Fold
  1201. /*
  1202. [Obsolete ("Use Aggregate instead")]
  1203. [System.Runtime.CompilerServices.Extension]
  1204. public static TSource Fold<TSource> (
  1205. IQueryable<TSource> source,
  1206. Func<TSource, TSource, TSource> func)
  1207. {
  1208. return Fold<TSource> (source, func);
  1209. }
  1210. [Obsolete ("Use Aggregate instead")]
  1211. [System.Runtime.CompilerServices.Extension]
  1212. public static U Fold<TSource, U> (
  1213. IQueryable<TSource> source,
  1214. U seed,
  1215. Func<U, TSource, U> func)
  1216. {
  1217. return Fold<TSource, U> (source, seed, func);
  1218. }
  1219. */
  1220. #endregion
  1221. #region Aggregate
  1222. public static TSource Aggregate<TSource> (
  1223. this IQueryable<TSource> source,
  1224. Func<TSource, TSource, TSource> func)
  1225. {
  1226. if (source == null || func == null)
  1227. throw new ArgumentNullException ();
  1228. int counter = 0;
  1229. TSource folded = default (TSource);
  1230. foreach (TSource element in source) {
  1231. if (counter == 0)
  1232. folded = element;
  1233. else
  1234. folded = func (folded, element);
  1235. }
  1236. if (counter == 0)
  1237. throw new InvalidOperationException ();
  1238. else
  1239. return folded;
  1240. }
  1241. public static U Aggregate<TSource, U> (
  1242. this IQueryable<TSource> source,
  1243. U seed,
  1244. Func<U, TSource, U> func)
  1245. {
  1246. if (source == null || func == null)
  1247. throw new ArgumentNullException ();
  1248. U folded = seed;
  1249. foreach (TSource element in source)
  1250. folded = func (folded, element);
  1251. return folded;
  1252. }
  1253. #endregion
  1254. #region Concat
  1255. public static IEnumerable<TSource> Concat<TSource> (
  1256. this IQueryable<TSource> first,
  1257. IEnumerable<TSource> second)
  1258. {
  1259. if (first == null || second == null)
  1260. throw new ArgumentNullException ();
  1261. foreach (TSource element in first)
  1262. yield return element;
  1263. foreach (TSource element in second)
  1264. yield return element;
  1265. }
  1266. #endregion
  1267. /*
  1268. #region ToSequence
  1269. [System.Runtime.CompilerServices.Extension]
  1270. public static IQueryable<TSource> ToSequence<TSource> (
  1271. IQueryable<TSource> source)
  1272. {
  1273. return (IQueryable<TSource>)source;
  1274. }
  1275. #endregion
  1276. #region ToArray
  1277. [System.Runtime.CompilerServices.Extension]
  1278. public static TSource[] ToArray<TSource> (
  1279. IQueryable<TSource> source)
  1280. {
  1281. if (source == null)
  1282. throw new ArgumentNullException ();
  1283. List<TSource> list = new List<TSource> (source);
  1284. return list.ToArray ();
  1285. }
  1286. #endregion
  1287. #region ToList
  1288. [System.Runtime.CompilerServices.Extension]
  1289. public static List<TSource> ToList<TSource> (
  1290. IQueryable<TSource> source)
  1291. {
  1292. if (source == null)
  1293. throw new ArgumentNullException ();
  1294. return new List<TSource> (source);
  1295. }
  1296. #endregion
  1297. #region ToDictionary
  1298. [System.Runtime.CompilerServices.Extension]
  1299. public static Dictionary<K, TSource> ToDictionary<TSource, K> (
  1300. IQueryable<TSource> source,
  1301. Func<TSource, K> keySelector)
  1302. {
  1303. return ToDictionary<TSource, K> (source, keySelector, null);
  1304. }
  1305. [System.Runtime.CompilerServices.Extension]
  1306. public static Dictionary<K, TSource> ToDictionary<TSource, K> (
  1307. IQueryable<TSource> source,
  1308. Func<TSource, K> keySelector,
  1309. IEqualityComparer<K> comparer)
  1310. {
  1311. if (source == null || keySelector == null)
  1312. throw new ArgumentNullException ();
  1313. Dictionary<K, TSource> dictionary = new Dictionary<K, TSource> (comparer ?? EqualityComparer<K>.Default);
  1314. foreach (TSource element in source) {
  1315. K key = keySelector (element);
  1316. if (key == null)
  1317. throw new ArgumentNullException ();
  1318. else if (dictionary.ContainsKey (key))
  1319. throw new ArgumentException ();
  1320. else
  1321. dictionary.Add (key, element);
  1322. }
  1323. return dictionary;
  1324. }
  1325. [System.Runtime.CompilerServices.Extension]
  1326. public static Dictionary<K, E> ToDictionary<TSource, K, E> (
  1327. IQueryable<TSource> source,
  1328. Func<TSource, K> keySelector,
  1329. Func<TSource, E> elementSelector)
  1330. {
  1331. return ToDictionary<TSource, K, E> (source, keySelector, elementSelector, null);
  1332. }
  1333. [System.Runtime.CompilerServices.Extension]
  1334. public static Dictionary<K, E> ToDictionary<TSource, K, E> (
  1335. IQueryable<TSource> source,
  1336. Func<TSource, K> keySelector,
  1337. Func<TSource, E> elementSelector,
  1338. IEqualityComparer<K> comparer)
  1339. {
  1340. if (source == null || keySelector == null || elementSelector == null)
  1341. throw new ArgumentNullException ();
  1342. Dictionary<K, E> dictionary = new Dictionary<K, E>(comparer ?? EqualityComparer<K>.Default);
  1343. foreach (TSource element in source)
  1344. {
  1345. K key = keySelector (element);
  1346. if (key == null)
  1347. throw new ArgumentNullException ();
  1348. else if (dictionary.ContainsKey (key))
  1349. throw new ArgumentException ();
  1350. else
  1351. dictionary.Add(key, elementSelector (element));
  1352. }
  1353. return dictionary;
  1354. }
  1355. #endregion
  1356. #region ToLookup
  1357. [System.Runtime.CompilerServices.Extension]
  1358. public static Lookup<K, TSource> ToLookup<TSource, K> (
  1359. IQueryable<TSource> source,
  1360. Func<TSource, K> keySelector)
  1361. {
  1362. return ToLookup<TSource, K> (source, keySelector, null);
  1363. }
  1364. [System.Runtime.CompilerServices.Extension]
  1365. public static Lookup<K, TSource> ToLookup<TSource, K> (
  1366. IQueryable<TSource> source,
  1367. Func<TSource, K> keySelector,
  1368. IEqualityComparer<K> comparer)
  1369. {
  1370. if (source == null || keySelector == null)
  1371. throw new ArgumentNullException ();
  1372. Dictionary<K, List<TSource>> dictionary = new Dictionary<K, List<TSource>> (comparer ?? EqualityComparer<K>.Default);
  1373. foreach (TSource element in source) {
  1374. K key = keySelector (element);
  1375. if (key == null)
  1376. throw new ArgumentNullException ();
  1377. if (!dictionary.ContainsKey (key))
  1378. dictionary.Add (key, new List<TSource> ());
  1379. dictionary[key].Add (element);
  1380. }
  1381. return new Lookup<K, TSource> (dictionary);
  1382. }
  1383. [System.Runtime.CompilerServices.Extension]
  1384. public static Lookup<K, E> ToLookup<TSource, K, E> (
  1385. IQueryable<TSource> source,
  1386. Func<TSource, K> keySelector,
  1387. Func<TSource, E> elementSelector)
  1388. {
  1389. return ToLookup<TSource, K, E> (source, keySelector, elementSelector, null);
  1390. }
  1391. [System.Runtime.CompilerServices.Extension]
  1392. public static Lookup<K, E> ToLookup<TSource, K, E> (
  1393. IQueryable<TSource> source,
  1394. Func<TSource, K> keySelector,
  1395. Func<TSource, E> elementSelector,
  1396. IEqualityComparer<K> comparer)
  1397. {
  1398. if (source == null || keySelector == null || elementSelector == null)
  1399. throw new ArgumentNullException ();
  1400. Dictionary<K, List<E>> dictionary = new Dictionary<K, List<E>>(comparer ?? EqualityComparer<K>.Default);
  1401. foreach (TSource element in source)
  1402. {
  1403. K key = keySelector (element);
  1404. if (key == null)
  1405. throw new ArgumentNullException ();
  1406. if (!dictionary.ContainsKey (key))
  1407. dictionary.Add (key, new List<E> ());
  1408. dictionary[key].Add (elementSelector (element));
  1409. }
  1410. return new Lookup<K, E> (dictionary);
  1411. }
  1412. #endregion
  1413. */
  1414. #region OfType
  1415. public static IEnumerable<TResult> OfType<TResult> (this IQueryable source)
  1416. {
  1417. if (source == null)
  1418. throw new ArgumentNullException ();
  1419. foreach (object element in source)
  1420. if (element is TResult)
  1421. yield return (TResult)element;
  1422. }
  1423. #endregion
  1424. #region Cast
  1425. public static IEnumerable<TResult> Cast<TResult> (this IQueryable source)
  1426. {
  1427. if (source == null)
  1428. throw new ArgumentNullException ();
  1429. foreach (object element in source)
  1430. yield return (TResult)element;
  1431. }
  1432. #endregion
  1433. #region First
  1434. public static TSource First<TSource> (this IQueryable<TSource> source)
  1435. {
  1436. if (source == null)
  1437. throw new ArgumentNullException ();
  1438. foreach (TSource element in source)
  1439. return element;
  1440. throw new InvalidOperationException ();
  1441. }
  1442. public static TSource First<TSource> (
  1443. this IQueryable<TSource> source,
  1444. Func<TSource, bool> predicate)
  1445. {
  1446. if (source == null || predicate == null)
  1447. throw new ArgumentNullException ();
  1448. foreach (TSource element in source) {
  1449. if (predicate (element))
  1450. return element;
  1451. }
  1452. throw new InvalidOperationException ();
  1453. }
  1454. #endregion
  1455. #region FirstOrDefault
  1456. public static TSource FirstOrDefault<TSource> (this IQueryable<TSource> source)
  1457. {
  1458. if (source == null)
  1459. throw new ArgumentNullException ();
  1460. foreach (TSource element in source)
  1461. return element;
  1462. return default (TSource);
  1463. }
  1464. public static TSource FirstOrDefault<TSource> (
  1465. this IQueryable<TSource> source,
  1466. Func<TSource, bool> predicate)
  1467. {
  1468. if (source == null || predicate == null)
  1469. throw new ArgumentNullException ();
  1470. foreach (TSource element in source) {
  1471. if (predicate (element))
  1472. return element;
  1473. }
  1474. return default (TSource);
  1475. }
  1476. #endregion
  1477. #region Last
  1478. public static TSource Last<TSource> (this IQueryable<TSource> source)
  1479. {
  1480. if (source == null)
  1481. throw new ArgumentNullException ();
  1482. bool noElements = true;
  1483. TSource lastElement = default (TSource);
  1484. foreach (TSource element in source)
  1485. {
  1486. if (noElements) noElements = false;
  1487. lastElement = element;
  1488. }
  1489. if (!noElements)
  1490. return lastElement;
  1491. else
  1492. throw new InvalidOperationException();
  1493. }
  1494. public static TSource Last<TSource> (
  1495. this IQueryable<TSource> source,
  1496. Func<TSource, bool> predicate)
  1497. {
  1498. if (source == null || predicate == null)
  1499. throw new ArgumentNullException ();
  1500. bool noElements = true;
  1501. TSource lastElement = default (TSource);
  1502. foreach (TSource element in source) {
  1503. if (predicate (element))
  1504. {
  1505. if (noElements) noElements = false;
  1506. lastElement = element;
  1507. }
  1508. }
  1509. if (!noElements)
  1510. return lastElement;
  1511. else
  1512. throw new InvalidOperationException ();
  1513. }
  1514. #endregion
  1515. #region LastOrDefault
  1516. public static TSource LastOrDefault<TSource> (this IQueryable<TSource> source)
  1517. {
  1518. if (source == null)
  1519. throw new ArgumentNullException ();
  1520. TSource lastElement = default (TSource);
  1521. foreach (TSource element in source)
  1522. lastElement = element;
  1523. return lastElement;
  1524. }
  1525. public static TSource LastOrDefault<TSource> (
  1526. this IQueryable<TSource> source,
  1527. Func<TSource, bool> predicate)
  1528. {
  1529. if (source == null || predicate == null)
  1530. throw new ArgumentNullException ();
  1531. TSource lastElement = default (TSource);
  1532. foreach (TSource element in source) {
  1533. if (predicate (element))
  1534. lastElement = element;
  1535. }
  1536. return lastElement;
  1537. }
  1538. #endregion
  1539. #region Single
  1540. public static TSource Single<TSource> (this IQueryable<TSource> source)
  1541. {
  1542. if (source == null)
  1543. throw new ArgumentNullException ();
  1544. bool otherElement = false;
  1545. TSource singleElement = default (TSource);
  1546. foreach (TSource element in source)
  1547. {
  1548. if (otherElement) throw new InvalidOperationException ();
  1549. if (!otherElement) otherElement = true;
  1550. singleElement = element;
  1551. }
  1552. if (otherElement)
  1553. return singleElement;
  1554. else
  1555. throw new InvalidOperationException();
  1556. }
  1557. public static TSource Single<TSource> (
  1558. this IQueryable<TSource> source,
  1559. Func<TSource, bool> predicate)
  1560. {
  1561. if (source == null || predicate == null)
  1562. throw new ArgumentNullException ();
  1563. bool otherElement = false;
  1564. TSource singleElement = default (TSource);
  1565. foreach (TSource element in source) {
  1566. if (predicate (element))
  1567. {
  1568. if (otherElement) throw new InvalidOperationException ();
  1569. if (!otherElement) otherElement = true;
  1570. singleElement = element;
  1571. }
  1572. }
  1573. if (otherElement)
  1574. return singleElement;
  1575. else
  1576. throw new InvalidOperationException ();
  1577. }
  1578. #endregion
  1579. #region SingleOrDefault
  1580. public static TSource SingleOrDefault<TSource> (this IQueryable<TSource> source)
  1581. {
  1582. if (source == null)
  1583. throw new ArgumentNullException ();
  1584. bool otherElement = false;
  1585. TSource singleElement = default (TSource);
  1586. foreach (TSource element in source)
  1587. {
  1588. if (otherElement) throw new InvalidOperationException ();
  1589. if (!otherElement) otherElement = true;
  1590. singleElement = element;
  1591. }
  1592. return singleElement;
  1593. }
  1594. public static TSource SingleOrDefault<TSource> (
  1595. this IQueryable<TSource> source,
  1596. Func<TSource, bool> predicate)
  1597. {
  1598. if (source == null || predicate == null)
  1599. throw new ArgumentNullException ();
  1600. bool otherElement = false;
  1601. TSource singleElement = default (TSource);
  1602. foreach (TSource element in source) {
  1603. if (predicate (element))
  1604. {
  1605. if (otherElement) throw new InvalidOperationException ();
  1606. if (!otherElement) otherElement = true;
  1607. singleElement = element;
  1608. }
  1609. }
  1610. return singleElement;
  1611. }
  1612. #endregion
  1613. #region ElementAt
  1614. public static TSource ElementAt<TSource> (
  1615. this IQueryable<TSource> source,
  1616. int index)
  1617. {
  1618. if (source == null)
  1619. throw new ArgumentNullException ();
  1620. if (index < 0)
  1621. throw new ArgumentOutOfRangeException ();
  1622. if (source is IList<TSource>)
  1623. return ((IList<TSource>)source)[index];
  1624. else {
  1625. int counter = 0;
  1626. foreach (TSource element in source) {
  1627. if (counter == index)
  1628. return element;
  1629. counter++;
  1630. }
  1631. throw new ArgumentOutOfRangeException();
  1632. }
  1633. }
  1634. #endregion
  1635. #region ElementAtOrDefault
  1636. public static TSource ElementAtOrDefault<TSource> (
  1637. this IQueryable<TSource> source,
  1638. int index)
  1639. {
  1640. if (source == null)
  1641. throw new ArgumentNullException ();
  1642. if (index < 0)
  1643. return default(TSource);
  1644. if (source is IList<TSource>)
  1645. {
  1646. if (((IList<TSource>)source).Count >= index)
  1647. return default(TSource);
  1648. else
  1649. return ((IList<TSource>)source)[index];
  1650. }
  1651. else {
  1652. int counter = 0;
  1653. foreach (TSource element in source) {
  1654. if (counter == index)
  1655. return element;
  1656. counter++;
  1657. }
  1658. return default (TSource);
  1659. }
  1660. }
  1661. #endregion
  1662. #region DefaultIfEmpty
  1663. public static IEnumerable<TSource> DefaultIfEmpty<TSource> (
  1664. this IQueryable<TSource> source)
  1665. {
  1666. if (source == null)
  1667. throw new ArgumentNullException ();
  1668. bool noYield = true;
  1669. foreach (TSource item in source)
  1670. {
  1671. noYield = false;
  1672. yield return item;
  1673. }
  1674. if (noYield)
  1675. yield return default (TSource);
  1676. }
  1677. public static IEnumerable<TSource> DefaultIfEmpty<TSource> (
  1678. this IQueryable<TSource> source,
  1679. TSource defaultValue)
  1680. {
  1681. if (source == null)
  1682. throw new ArgumentNullException ();
  1683. bool noYield = true;
  1684. foreach (TSource item in source)
  1685. {
  1686. noYield = false;
  1687. yield return item;
  1688. }
  1689. if (noYield)
  1690. yield return defaultValue;
  1691. }
  1692. #endregion
  1693. /* #region EqualAll
  1694. [System.Runtime.CompilerServices.Extension]
  1695. public static bool EqualAll<TSource> (
  1696. IQueryable<TSource> first,
  1697. IQueryable<TSource> second)
  1698. {
  1699. if (first == null || second == null)
  1700. throw new ArgumentNullException ();
  1701. List<TSource> firstList = new List<TSource> (first);
  1702. List<TSource> secondList = new List<TSource> (second);
  1703. if (firstList.Count != firstList.Count)
  1704. return false;
  1705. for (int i = 0; i < firstList.Count; i++) {
  1706. if (!System.Object.Equals (firstList [i], secondList [i]))
  1707. return false;
  1708. }
  1709. // If no pair of elements is different, then everything is equal
  1710. return true;
  1711. }
  1712. #endregion
  1713. #region Range
  1714. [System.Runtime.CompilerServices.Extension]
  1715. public static IEnumerable<int> Range (
  1716. int start, int count)
  1717. {
  1718. if (count < 0 || (start + count - 1) > int.MaxValue)
  1719. throw new ArgumentOutOfRangeException ();
  1720. for (int i = start; i < (start + count - 1); i++)
  1721. yield return i;
  1722. }
  1723. #endregion
  1724. */
  1725. #region Repeat
  1726. public static IEnumerable<TSource> Repeat<TSource> (this TSource element, int count)
  1727. {
  1728. if (count < 0)
  1729. throw new ArgumentOutOfRangeException ();
  1730. for (int i = 0; i < count; i++)
  1731. yield return element;
  1732. }
  1733. #endregion
  1734. /** A NOTE ON IMPLEMENTATION REGARDING NULL KEYS
  1735. *
  1736. * GroupBy specification states that null-key values
  1737. * are allowed. However, all implementations of
  1738. * Dictionary<K, TSource> ban null keys.
  1739. * Because of this, a small trick has to be done:
  1740. * a special List<TSource> variable is created in order to
  1741. * be filled with this null-key values.
  1742. * Also, groups must be yielded in the order their
  1743. * keys were found for first time, so we need to keep
  1744. * a record on when the null-key values appeared
  1745. * (that is nullCounter variable).
  1746. * Then, when results are iterated and yielded, we
  1747. * mantain a counter and if null-key values were
  1748. * found, they are yielded in the order needed.
  1749. * Because K can be a valuetype, compilers expose a
  1750. * restriction on null values, that's why default(TSource)
  1751. * is used. However, default(TSource) is null for
  1752. * reference types, and values with selectors that
  1753. * return value types can't return null. **/
  1754. #region GroupBy
  1755. private static List<TSource> ContainsGroup<K, TSource>(
  1756. Dictionary<K, List<TSource>> items, K key, IEqualityComparer<K> comparer)
  1757. {
  1758. IEqualityComparer<K> comparerInUse = (comparer ?? EqualityComparer<K>.Default);
  1759. foreach (KeyValuePair<K, List<TSource>> value in items) {
  1760. if (comparerInUse.Equals(value.Key, key))
  1761. return value.Value;
  1762. }
  1763. return null;
  1764. }
  1765. public static IQueryable<IGrouping<K, TSource>> GroupBy<TSource, K> (
  1766. this IQueryable<TSource> source,
  1767. Func<TSource, K> keySelector)
  1768. {
  1769. throw new NotImplementedException ();
  1770. //return GroupBy<TSource, K> (source, keySelector, null);
  1771. }
  1772. /*
  1773. [System.Runtime.CompilerServices.Extension]
  1774. public static IQueryable<IGrouping<K, TSource>> GroupBy<TSource, K> (
  1775. IQueryable<TSource> source,
  1776. Func<TSource, K> keySelector,
  1777. IEqualityComparer<K> comparer)
  1778. {
  1779. if (source == null || keySelector == null)
  1780. throw new ArgumentNullException ();
  1781. Dictionary<K, List<TSource>> groups = new Dictionary<K, List<TSource>> ();
  1782. List<TSource> nullList = new List<TSource> ();
  1783. int counter = 0;
  1784. int nullCounter = -1;
  1785. foreach (TSource element in source) {
  1786. K key = keySelector (element);
  1787. if (key == null) {
  1788. nullList.Add (element);
  1789. if (nullCounter == -1) {
  1790. nullCounter = counter;
  1791. counter++;
  1792. }
  1793. }
  1794. else {
  1795. List<TSource> group = ContainsGroup<K, TSource> (groups, key, comparer);
  1796. if (group == null) {
  1797. group = new List<TSource> ();
  1798. groups.Add (key, group);
  1799. counter++;
  1800. }
  1801. group.Add (element);
  1802. }
  1803. }
  1804. counter = 0;
  1805. foreach (KeyValuePair<K, List<TSource>> group in groups) {
  1806. if (counter == nullCounter) {
  1807. Grouping<K, TSource> nullGroup = new Grouping<K, TSource> (default (K), nullList);
  1808. yield return nullGroup;
  1809. counter++;
  1810. }
  1811. Grouping<K, TSource> grouping = new Grouping<K, TSource> (group.Key, group.Value);
  1812. yield return grouping;
  1813. counter++;
  1814. }
  1815. }
  1816. */
  1817. public static IQueryable<IGrouping<K, E>> GroupBy<TSource, K, E> (
  1818. this IQueryable<TSource> source,
  1819. Func<TSource, K> keySelector,
  1820. Func<TSource, E> elementSelector)
  1821. {
  1822. return GroupBy<TSource, K, E> (source, keySelector, elementSelector);
  1823. }
  1824. public static IEnumerable<IGrouping<K, E>> GroupBy<TSource, K, E> (
  1825. this IQueryable<TSource> source,
  1826. Func<TSource, K> keySelector,
  1827. Func<TSource, E> elementSelector,
  1828. IEqualityComparer<K> comparer)
  1829. {
  1830. if (source == null || keySelector == null || elementSelector == null)
  1831. throw new ArgumentNullException ();
  1832. Dictionary<K, List<E>> groups = new Dictionary<K, List<E>> ();
  1833. List<E> nullList = new List<E> ();
  1834. int counter = 0;
  1835. int nullCounter = -1;
  1836. foreach (TSource item in source) {
  1837. K key = keySelector (item);
  1838. E element = elementSelector (item);
  1839. if (key == null) {
  1840. nullList.Add(element);
  1841. if (nullCounter == -1) {
  1842. nullCounter = counter;
  1843. counter++;
  1844. }
  1845. }
  1846. else {
  1847. List<E> group = ContainsGroup<K, E> (groups, key, comparer);
  1848. if (group == null) {
  1849. group = new List<E> ();
  1850. groups.Add (key, group);
  1851. counter++;
  1852. }
  1853. group.Add (element);
  1854. }
  1855. }
  1856. counter = 0;
  1857. foreach (KeyValuePair<K, List<E>> group in groups) {
  1858. if (counter == nullCounter) {
  1859. Grouping<K, E> nullGroup = new Grouping<K, E> (default (K), nullList);
  1860. yield return nullGroup;
  1861. counter++;
  1862. }
  1863. Grouping<K, E> grouping = new Grouping<K, E> (group.Key, group.Value);
  1864. yield return grouping;
  1865. counter++;
  1866. }
  1867. }
  1868. #endregion
  1869. #region OrderBy
  1870. public static OrderedSequence<TSource> OrderBy<TSource, K> (
  1871. this IQueryable<TSource> source,
  1872. Func<TSource, K> keySelector)
  1873. {
  1874. return OrderBy<TSource, K> (source, keySelector, null);
  1875. }
  1876. public static OrderedSequence<TSource> OrderBy<TSource, K> (
  1877. this IQueryable<TSource> source,
  1878. Func<TSource, K> keySelector,
  1879. IComparer<K> comparer)
  1880. {
  1881. if (source == null || keySelector == null)
  1882. throw new ArgumentNullException ();
  1883. return new InternalOrderedSequence<TSource, K> (
  1884. source, keySelector, (comparer ?? Comparer<K>.Default), false, null);
  1885. }
  1886. #endregion
  1887. #region OrderByDescending
  1888. public static OrderedSequence<TSource> OrderByDescending<TSource, K> (
  1889. this IQueryable<TSource> source,
  1890. Func<TSource, K> keySelector)
  1891. {
  1892. return OrderByDescending<TSource, K> (source, keySelector, null);
  1893. }
  1894. public static OrderedSequence<TSource> OrderByDescending<TSource, K> (
  1895. this IQueryable<TSource> source,
  1896. Func<TSource, K> keySelector,
  1897. IComparer<K> comparer)
  1898. {
  1899. if (source == null || keySelector == null)
  1900. throw new ArgumentNullException ();
  1901. return new InternalOrderedSequence<TSource, K> (
  1902. source, keySelector, (comparer ?? Comparer<K>.Default), true, null);
  1903. }
  1904. #endregion
  1905. #region ThenBy
  1906. public static OrderedSequence<TSource> ThenBy<TSource, K> (
  1907. this OrderedSequence<TSource> source,
  1908. Func<TSource, K> keySelector)
  1909. {
  1910. return ThenBy<TSource, K> (source, keySelector, null);
  1911. }
  1912. public static OrderedSequence<TSource> ThenBy<TSource, K> (
  1913. this OrderedSequence<TSource> source,
  1914. Func<TSource, K> keySelector,
  1915. IComparer<K> comparer)
  1916. {
  1917. if (source == null || keySelector == null)
  1918. throw new ArgumentNullException ();
  1919. return new InternalOrderedSequence<TSource, K> (
  1920. source, keySelector, (comparer ?? Comparer<K>.Default), false, source);
  1921. }
  1922. #endregion
  1923. #region ThenByDescending
  1924. public static OrderedSequence<TSource> ThenByDescending<TSource, K> (
  1925. this OrderedSequence<TSource> source,
  1926. Func<TSource, K> keySelector)
  1927. {
  1928. return ThenByDescending<TSource, K> (source, keySelector, null);
  1929. }
  1930. public static OrderedSequence<TSource> ThenByDescending<TSource, K> (
  1931. this OrderedSequence<TSource> source,
  1932. Func<TSource, K> keySelector,
  1933. IComparer<K> comparer)
  1934. {
  1935. if (source == null || keySelector == null)
  1936. throw new ArgumentNullException ();
  1937. return new InternalOrderedSequence<TSource, K> (
  1938. source, keySelector, (comparer ?? Comparer<K>.Default), true, source);
  1939. }
  1940. #endregion
  1941. #region Reverse
  1942. public static IQueryable<TSource> Reverse<TSource> (
  1943. this IQueryable<TSource> source)
  1944. {
  1945. if (source == null)
  1946. throw new ArgumentNullException ();
  1947. //List<TSource> list = new List<TSource> (source);
  1948. //list.Reverse ();
  1949. //return list;
  1950. throw new NotImplementedException ();
  1951. }
  1952. #endregion
  1953. #region Take
  1954. public static IEnumerable<TSource> Take<TSource> (
  1955. this IQueryable<TSource> source,
  1956. int count)
  1957. {
  1958. if (source == null)
  1959. throw new ArgumentNullException ();
  1960. if (count <= 0)
  1961. yield break;
  1962. else {
  1963. int counter = 0;
  1964. foreach (TSource element in source) {
  1965. yield return element;
  1966. counter++;
  1967. if (counter == count)
  1968. yield break;
  1969. }
  1970. }
  1971. }
  1972. #endregion
  1973. #region Skip
  1974. public static IEnumerable<TSource> Skip<TSource> (
  1975. this IQueryable<TSource> source,
  1976. int count)
  1977. {
  1978. if (source == null)
  1979. throw new ArgumentNullException ();
  1980. int counter = 0;
  1981. bool yield = false;
  1982. if (count <= 0)
  1983. yield = true;
  1984. foreach (TSource element in source) {
  1985. if (yield)
  1986. yield return element;
  1987. else {
  1988. counter++;
  1989. if (counter == count)
  1990. yield = true;
  1991. }
  1992. }
  1993. }
  1994. #endregion
  1995. #region TakeWhile
  1996. public static IEnumerable<TSource> TakeWhile<TSource> (
  1997. this IQueryable<TSource> source,
  1998. Func<TSource, bool> predicate)
  1999. {
  2000. if (source == null || predicate == null)
  2001. throw new ArgumentNullException ();
  2002. foreach (TSource element in source) {
  2003. if (predicate (element))
  2004. yield return element;
  2005. else
  2006. yield break;
  2007. }
  2008. }
  2009. public static IEnumerable<TSource> TakeWhile<TSource> (
  2010. this IQueryable<TSource> source,
  2011. Func<TSource, int, bool> predicate)
  2012. {
  2013. if (source == null || predicate == null)
  2014. throw new ArgumentNullException ();
  2015. int counter = 0;
  2016. foreach (TSource element in source)
  2017. {
  2018. if (predicate (element, counter))
  2019. yield return element;
  2020. else
  2021. yield break;
  2022. counter++;
  2023. }
  2024. }
  2025. #endregion
  2026. #region SkipWhile
  2027. public static IEnumerable<TSource> SkipWhile<TSource> (
  2028. this IQueryable<TSource> source,
  2029. Func<TSource, bool> predicate)
  2030. {
  2031. if (source == null || predicate == null)
  2032. throw new ArgumentNullException ();
  2033. bool yield = false;
  2034. foreach (TSource element in source) {
  2035. if (yield)
  2036. yield return element;
  2037. else
  2038. if (!predicate (element)) {
  2039. yield return element;
  2040. yield = true;
  2041. }
  2042. }
  2043. }
  2044. public static IEnumerable<TSource> SkipWhile<TSource> (
  2045. this IQueryable<TSource> source,
  2046. Func<TSource, int, bool> predicate)
  2047. {
  2048. if (source == null || predicate == null)
  2049. throw new ArgumentNullException();
  2050. int counter = 0;
  2051. bool yield = false;
  2052. foreach (TSource element in source) {
  2053. if (yield)
  2054. yield return element;
  2055. else
  2056. if (!predicate (element, counter)) {
  2057. yield return element;
  2058. yield = true;
  2059. }
  2060. counter++;
  2061. }
  2062. }
  2063. #endregion
  2064. #region Select
  2065. public static IEnumerable<TResult> Select<TSource, TResult> (
  2066. this IQueryable<TSource> source,
  2067. Func<TSource, TResult> selector)
  2068. {
  2069. if (source == null || selector == null)
  2070. throw new ArgumentNullException ();
  2071. foreach (TSource element in source)
  2072. yield return selector (element);
  2073. }
  2074. public static IEnumerable<TResult> Select<TSource, TResult> (
  2075. this IQueryable<TSource> source,
  2076. Func<TSource, int, TResult> selector)
  2077. {
  2078. if (source == null || selector == null)
  2079. throw new ArgumentNullException ();
  2080. int counter = 0;
  2081. foreach (TSource element in source) {
  2082. yield return selector (element, counter);
  2083. counter++;
  2084. }
  2085. }
  2086. #endregion
  2087. #region SelectMany
  2088. public static IEnumerable<TResult> SelectMany<TSource, TResult> (
  2089. this IQueryable<TSource> source,
  2090. Func<TSource, IQueryable<TResult>> selector)
  2091. {
  2092. if (source == null || selector == null)
  2093. throw new ArgumentNullException ();
  2094. foreach (TSource element in source)
  2095. foreach (TResult item in selector (element))
  2096. yield return item;
  2097. }
  2098. public static IEnumerable<TResult> SelectMany<TSource, TResult> (
  2099. this IQueryable<TSource> source,
  2100. Func<TSource, int, IQueryable<TResult>> selector)
  2101. {
  2102. if (source == null || selector == null)
  2103. throw new ArgumentNullException ();
  2104. int counter = 0;
  2105. foreach (TSource element in source) {
  2106. foreach (TResult item in selector (element, counter))
  2107. yield return item;
  2108. counter++;
  2109. }
  2110. }
  2111. #endregion
  2112. #region Any
  2113. public static bool Any<TSource> (this IQueryable<TSource> source)
  2114. {
  2115. if (source == null)
  2116. throw new ArgumentNullException ();
  2117. foreach (TSource element in source)
  2118. return true;
  2119. return false;
  2120. }
  2121. public static bool Any<TSource> (
  2122. this IQueryable<TSource> source,
  2123. Func<TSource, bool> predicate)
  2124. {
  2125. if (source == null || predicate == null)
  2126. throw new ArgumentNullException ();
  2127. foreach (TSource element in source)
  2128. if (predicate(element))
  2129. return true;
  2130. return false;
  2131. }
  2132. #endregion
  2133. #region All
  2134. public static bool All<TSource> (
  2135. this IQueryable<TSource> source,
  2136. Func<TSource, bool> predicate)
  2137. {
  2138. if (source == null || predicate == null)
  2139. throw new ArgumentNullException ();
  2140. foreach (TSource element in source)
  2141. if (!predicate(element))
  2142. return false;
  2143. return true;
  2144. }
  2145. #endregion
  2146. #region Contains
  2147. public static bool Contains<TSource> (this IQueryable<TSource> source, TSource value)
  2148. {
  2149. if (source is ICollection<TSource>) {
  2150. ICollection<TSource> collection = (ICollection<TSource>)source;
  2151. return collection.Contains(value);
  2152. }
  2153. else {
  2154. foreach (TSource element in source)
  2155. if (Equals(element, value))
  2156. return true;
  2157. return false;
  2158. }
  2159. }
  2160. #endregion
  2161. #region Where
  2162. public static IEnumerable<TSource> Where<TSource> (
  2163. this IQueryable<TSource> source,
  2164. Func<TSource, bool> predicate)
  2165. {
  2166. if (source == null || predicate == null)
  2167. throw new ArgumentNullException ();
  2168. foreach (TSource element in source)
  2169. if (predicate (element))
  2170. yield return element;
  2171. }
  2172. public static IEnumerable<TSource> Where<TSource> (
  2173. this IQueryable<TSource> source,
  2174. Func<TSource, int, bool> predicate)
  2175. {
  2176. if (source == null || predicate == null)
  2177. throw new ArgumentNullException ();
  2178. int counter = 0;
  2179. foreach (TSource element in source) {
  2180. if (predicate (element, counter))
  2181. yield return element;
  2182. counter++;
  2183. }
  2184. }
  2185. #endregion
  2186. #region Distinct
  2187. /* [System.Runtime.CompilerServices.Extension]
  2188. public static IQueryable<TSource> Distinct<TSource> (
  2189. IQueryable<TSource> source)
  2190. {
  2191. if (source == null)
  2192. throw new ArgumentNullException ();
  2193. List<TSource> items = new List<TSource> ();
  2194. foreach (TSource element in source) {
  2195. if (IndexOf (items, element) == -1) {
  2196. items.Add (element);
  2197. yield return element;
  2198. }
  2199. }
  2200. }*/
  2201. #endregion
  2202. #region Union
  2203. /* [System.Runtime.CompilerServices.Extension]
  2204. public static IQueryable<TSource> Union<TSource> (
  2205. IQueryable<TSource> first,
  2206. IQueryable<TSource> second)
  2207. {
  2208. if (first == null || second == null)
  2209. throw new ArgumentNullException ();
  2210. List<TSource> items = new List<TSource> ();
  2211. foreach (TSource element in first) {
  2212. if (IndexOf (items, element) == -1) {
  2213. items.Add (element);
  2214. yield return element;
  2215. }
  2216. }
  2217. foreach (TSource element in second) {
  2218. if (IndexOf (items, element) == -1) {
  2219. items.Add (element);
  2220. yield return element;
  2221. }
  2222. }
  2223. }*/
  2224. #endregion
  2225. #region Intersect
  2226. /* [System.Runtime.CompilerServices.Extension]
  2227. public static IQueryable<TSource> Intersect<TSource> (
  2228. IQueryable<TSource> first,
  2229. IQueryable<TSource> second)
  2230. {
  2231. if (first == null || second == null)
  2232. throw new ArgumentNullException ();
  2233. List<TSource> items = new List<TSource> (Distinct (first));
  2234. bool[] marked = new bool [items.Count];
  2235. for (int i = 0; i < marked.Length; i++)
  2236. marked[i] = false;
  2237. foreach (TSource element in second) {
  2238. int index = IndexOf (items, element);
  2239. if (index != -1)
  2240. marked [index] = true;
  2241. }
  2242. for (int i = 0; i < marked.Length; i++) {
  2243. if (marked [i])
  2244. yield return items [i];
  2245. }
  2246. }*/
  2247. #endregion
  2248. #region Except
  2249. /*[System.Runtime.CompilerServices.Extension]
  2250. public static IQueryable<TSource> Except<TSource> (
  2251. IQueryable<TSource> first,
  2252. IQueryable<TSource> second)
  2253. {
  2254. if (first == null || second == null)
  2255. throw new ArgumentNullException ();
  2256. List<TSource> items = new List<TSource> (Distinct (first));
  2257. foreach (TSource element in second) {
  2258. int index = IndexOf (items, element);
  2259. if (index == -1)
  2260. items.Add (element);
  2261. else
  2262. items.RemoveAt (index);
  2263. }
  2264. foreach (TSource item in items)
  2265. yield return item;
  2266. }*/
  2267. #endregion
  2268. # region Join
  2269. public static IEnumerable<V> Join<TSource, U, K, V> (
  2270. this IQueryable<TSource> outer,
  2271. IQueryable<U> inner,
  2272. Func<TSource, K> outerKeySelector,
  2273. Func<U, K> innerKeySelector,
  2274. Func<TSource, U, V> resultSelector)
  2275. {
  2276. if (outer == null || inner == null || outerKeySelector == null ||
  2277. innerKeySelector == null || resultSelector == null)
  2278. throw new ArgumentNullException ();
  2279. /*Lookup<K, U> innerKeys = ToLookup<U, K> (inner, innerKeySelector);
  2280. /*Dictionary<K, List<U>> innerKeys = new Dictionary<K, List<U>> ();
  2281. foreach (U element in inner)
  2282. {
  2283. K innerKey = innerKeySelector (element);
  2284. if (!innerKeys.ContainsKey (innerKey))
  2285. innerKeys.Add (innerKey, new List<U> ());
  2286. innerKeys[innerKey].Add (element);
  2287. }*/
  2288. /*
  2289. foreach (TSource element in outer)
  2290. {
  2291. K outerKey = outerKeySelector (element);
  2292. if (innerKeys.Contains (outerKey))
  2293. {
  2294. foreach (U innerElement in innerKeys [outerKey])
  2295. yield return resultSelector (element, innerElement);
  2296. }
  2297. }*/
  2298. throw new NotImplementedException ();
  2299. }
  2300. # endregion
  2301. # region GroupJoin
  2302. /*[System.Runtime.CompilerServices.Extension]
  2303. public static IQueryable<V> GroupJoin<TSource, U, K, V> (
  2304. IQueryable<TSource> outer,
  2305. IQueryable<U> inner,
  2306. Func<TSource, K> outerKeySelector,
  2307. Func<U, K> innerKeySelector,
  2308. Func<TSource, IQueryable<U>, V> resultSelector)
  2309. {
  2310. if (outer == null || inner == null || outerKeySelector == null ||
  2311. innerKeySelector == null || resultSelector == null)
  2312. throw new ArgumentNullException ();
  2313. Lookup<K, U> innerKeys = ToLookup<U, K> (inner, innerKeySelector);
  2314. /*Dictionary<K, List<U>> innerKeys = new Dictionary<K, List<U>> ();
  2315. foreach (U element in inner)
  2316. {
  2317. K innerKey = innerKeySelector (element);
  2318. if (!innerKeys.ContainsKey (innerKey))
  2319. innerKeys.Add (innerKey, new List<U> ());
  2320. innerKeys[innerKey].Add (element);
  2321. }*/
  2322. /*foreach (TSource element in outer)
  2323. {
  2324. K outerKey = outerKeySelector (element);
  2325. if (innerKeys.Contains (outerKey))
  2326. yield return resultSelector (element, innerKeys [outerKey]);
  2327. }
  2328. }*/
  2329. # endregion
  2330. // These methods are not included in the
  2331. // .NET Standard Query Operators Specification,
  2332. // but they provide additional useful commands
  2333. #region Compare
  2334. private static bool Equals<TSource> (
  2335. this TSource first, TSource second)
  2336. {
  2337. // Mostly, values in Enumerable<TSource>
  2338. // sequences need to be compared using
  2339. // Equals and GetHashCode
  2340. if (first == null || second == null)
  2341. return (first == null && second == null);
  2342. else
  2343. return ((first.Equals (second) ||
  2344. first.GetHashCode () == second.GetHashCode ()));
  2345. }
  2346. #endregion
  2347. /*
  2348. #region IndexOf
  2349. [System.Runtime.CompilerServices.Extension]
  2350. public static int IndexOf<TSource>(
  2351. IQueryable<TSource> source,
  2352. TSource item)
  2353. {
  2354. int counter = 0;
  2355. foreach (TSource element in source) {
  2356. if (Equals(element, item))
  2357. return counter;
  2358. counter++;
  2359. }
  2360. // The item was not found
  2361. return -1;
  2362. }
  2363. #endregion
  2364. */
  2365. }
  2366. }