123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880 |
- // Licensed to the .NET Foundation under one or more agreements.
- // The .NET Foundation licenses this file to you under the Apache 2.0 License.
- // See the LICENSE file in the project root for more information.
- using System.Collections.Generic;
- using System.ComponentModel;
- using System.Globalization;
- using System.Linq.Expressions;
- using System.Reflection;
- namespace System.Linq
- {
- /// <summary>
- /// Provides a set of additional static methods that allow querying enumerable sequences.
- /// </summary>
- public static class QueryableEx
- {
- /// <summary>
- /// Determines whether an enumerable sequence is empty.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <returns>true if the sequence is empty; false otherwise.</returns>
- public static bool IsEmpty<TSource>(this IQueryable<TSource> source)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.Execute<bool>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.IsEmpty<TSource>(default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static bool IsEmpty<TSource>(IEnumerable<TSource> source)
- {
- return EnumerableEx.IsEmpty(source);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the minimum value in the enumerable sequence by using the specified comparer to compare values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="comparer">Comparer used to determine the minimum value.</param>
- /// <returns>Minimum value in the sequence.</returns>
- public static TSource Min<TSource>(this IQueryable<TSource> source, IComparer<TSource> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.Execute<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Min<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(comparer, typeof(IComparer<TSource>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static TSource Min<TSource>(IEnumerable<TSource> source, IComparer<TSource> comparer)
- {
- return EnumerableEx.Min(source, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the elements with the minimum key value by using the default comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector used to extract the key for each element in the sequence.</param>
- /// <returns>List with the elements that share the same minimum key value.</returns>
- public static IList<TSource> MinBy<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- return source.Provider.Execute<IList<TSource>>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.MinBy<TSource, TKey>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IList<TSource> MinBy<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
- {
- return EnumerableEx.MinBy(source, keySelector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the elements with the minimum key value by using the specified comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector used to extract the key for each element in the sequence.</param>
- /// <param name="comparer">Comparer used to determine the minimum key value.</param>
- /// <returns>List with the elements that share the same minimum key value.</returns>
- public static IList<TSource> MinBy<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector, IComparer<TKey> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.Execute<IList<TSource>>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.MinBy<TSource, TKey>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector,
- Expression.Constant(comparer, typeof(IComparer<TKey>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IList<TSource> MinBy<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector, IComparer<TKey> comparer)
- {
- return EnumerableEx.MinBy(source, keySelector, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the maximum value in the enumerable sequence by using the specified comparer to compare values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="comparer">Comparer used to determine the maximum value.</param>
- /// <returns>Maximum value in the sequence.</returns>
- public static TSource Max<TSource>(this IQueryable<TSource> source, IComparer<TSource> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.Execute<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Max<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(comparer, typeof(IComparer<TSource>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static TSource Max<TSource>(IEnumerable<TSource> source, IComparer<TSource> comparer)
- {
- return EnumerableEx.Max(source, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the elements with the maximum key value by using the default comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector used to extract the key for each element in the sequence.</param>
- /// <returns>List with the elements that share the same maximum key value.</returns>
- public static IList<TSource> MaxBy<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- return source.Provider.Execute<IList<TSource>>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.MaxBy<TSource, TKey>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IList<TSource> MaxBy<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
- {
- return EnumerableEx.MaxBy(source, keySelector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the elements with the minimum key value by using the specified comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector used to extract the key for each element in the sequence.</param>
- /// <param name="comparer">Comparer used to determine the maximum key value.</param>
- /// <returns>List with the elements that share the same maximum key value.</returns>
- public static IList<TSource> MaxBy<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector, IComparer<TKey> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.Execute<IList<TSource>>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.MaxBy<TSource, TKey>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector,
- Expression.Constant(comparer, typeof(IComparer<TKey>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IList<TSource> MaxBy<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector, IComparer<TKey> comparer)
- {
- return EnumerableEx.MaxBy(source, keySelector, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Shares the source sequence within a selector function where each enumerator can fetch the next element from the source sequence.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="selector">Selector function with shared access to the source sequence for each enumerator.</param>
- /// <returns>Sequence resulting from applying the selector function to the shared view over the source sequence.</returns>
- public static IQueryable<TResult> Share<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<IEnumerable<TSource>, IEnumerable<TResult>>> selector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- return source.Provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Share<TSource, TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TResult)),
- #endif
- source.Expression,
- selector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TResult> Share<TSource, TResult>(IEnumerable<TSource> source, Func<IEnumerable<TSource>, IEnumerable<TResult>> selector)
- {
- return EnumerableEx.Share(source, selector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Publishes the source sequence within a selector function where each enumerator can obtain a view over a tail of the source sequence.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="selector">Selector function with published access to the source sequence for each enumerator.</param>
- /// <returns>Sequence resulting from applying the selector function to the published view over the source sequence.</returns>
- public static IQueryable<TResult> Publish<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<IEnumerable<TSource>, IEnumerable<TResult>>> selector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- return source.Provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Publish<TSource, TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TResult)),
- #endif
- source.Expression,
- selector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TResult> Publish<TSource, TResult>(IEnumerable<TSource> source, Func<IEnumerable<TSource>, IEnumerable<TResult>> selector)
- {
- return EnumerableEx.Publish(source, selector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Memoizes the source sequence within a selector function where each enumerator can get access to all of the sequence's elements without causing multiple enumerations over the source.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="selector">Selector function with memoized access to the source sequence for each enumerator.</param>
- /// <returns>Sequence resulting from applying the selector function to the memoized view over the source sequence.</returns>
- public static IQueryable<TResult> Memoize<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<IEnumerable<TSource>, IEnumerable<TResult>>> selector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- return source.Provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Memoize<TSource, TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TResult)),
- #endif
- source.Expression,
- selector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TResult> Memoize<TSource, TResult>(IEnumerable<TSource> source, Func<IEnumerable<TSource>, IEnumerable<TResult>> selector)
- {
- return EnumerableEx.Memoize(source, selector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Memoizes the source sequence within a selector function where a specified number of enumerators can get access to all of the sequence's elements without causing multiple enumerations over the source.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="readerCount">Number of enumerators that can access the underlying buffer. Once every enumerator has obtained an element from the buffer, the element is removed from the buffer.</param>
- /// <param name="selector">Selector function with memoized access to the source sequence for a specified number of enumerators.</param>
- /// <returns>Sequence resulting from applying the selector function to the memoized view over the source sequence.</returns>
- public static IQueryable<TResult> Memoize<TSource, TResult>(this IQueryable<TSource> source, int readerCount, Expression<Func<IEnumerable<TSource>, IEnumerable<TResult>>> selector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- return source.Provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Memoize<TSource, TResult>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TResult)),
- #endif
- source.Expression,
- Expression.Constant(readerCount, typeof(int)),
- selector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TResult> Memoize<TSource, TResult>(IEnumerable<TSource> source, int readerCount, Func<IEnumerable<TSource>, IEnumerable<TResult>> selector)
- {
- return EnumerableEx.Memoize(source, readerCount, selector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates an enumerable sequence based on an enumerator factory function.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="getEnumerator">Enumerator factory function.</param>
- /// <returns>Sequence that will invoke the enumerator factory upon a call to GetEnumerator.</returns>
- public static IQueryable<TResult> Create<TResult>(this IQueryProvider provider, Expression<Func<IEnumerator<TResult>>> getEnumerator)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (getEnumerator == null)
- {
- throw new ArgumentNullException(nameof(getEnumerator));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Create<TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- getEnumerator
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TResult> Create<TResult>(Func<IEnumerator<TResult>> getEnumerator)
- {
- return EnumerableEx.Create(getEnumerator);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns a sequence with a single element.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="value">Single element of the resulting sequence.</param>
- /// <returns>Sequence with a single element.</returns>
- public static IQueryable<TResult> Return<TResult>(this IQueryProvider provider, TResult value)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Return<TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- Expression.Constant(value, typeof(TResult))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Return<TResult>(TResult value)
- {
- return EnumerableEx.Return(value).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns a sequence that throws an exception upon enumeration.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="exception">Exception to throw upon enumerating the resulting sequence.</param>
- /// <returns>Sequence that throws the specified exception upon enumeration.</returns>
- public static IQueryable<TResult> Throw<TResult>(this IQueryProvider provider, Exception exception)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (exception == null)
- {
- throw new ArgumentNullException(nameof(exception));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Throw<TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- Expression.Constant(exception, typeof(Exception))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Throw<TResult>(Exception exception)
- {
- return EnumerableEx.Throw<TResult>(exception).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates an enumerable sequence based on an enumerable factory function.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="enumerableFactory">Enumerable factory function.</param>
- /// <returns>Sequence that will invoke the enumerable factory upon a call to GetEnumerator.</returns>
- public static IQueryable<TResult> Defer<TResult>(this IQueryProvider provider, Expression<Func<IEnumerable<TResult>>> enumerableFactory)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (enumerableFactory == null)
- {
- throw new ArgumentNullException(nameof(enumerableFactory));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Defer<TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- enumerableFactory
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Defer<TResult>(Func<IEnumerable<TResult>> enumerableFactory)
- {
- return EnumerableEx.Defer(enumerableFactory).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence by mimicking a for loop.
- /// </summary>
- /// <typeparam name="TState">State type.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="initialState">Initial state of the generator loop.</param>
- /// <param name="condition">Loop condition.</param>
- /// <param name="iterate">State update function to run after every iteration of the generator loop.</param>
- /// <param name="resultSelector">Result selector to compute resulting sequence elements.</param>
- /// <returns>Sequence obtained by running the generator loop, yielding computed elements.</returns>
- public static IQueryable<TResult> Generate<TState, TResult>(this IQueryProvider provider, TState initialState, Expression<Func<TState, bool>> condition, Expression<Func<TState, TState>> iterate, Expression<Func<TState, TResult>> resultSelector)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (condition == null)
- {
- throw new ArgumentNullException(nameof(condition));
- }
- if (iterate == null)
- {
- throw new ArgumentNullException(nameof(iterate));
- }
- if (resultSelector == null)
- {
- throw new ArgumentNullException(nameof(resultSelector));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Generate<TState, TResult>(default, default, default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TState), typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- Expression.Constant(initialState),
- condition,
- iterate,
- resultSelector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Generate<TState, TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector)
- {
- return EnumerableEx.Generate(initialState, condition, iterate, resultSelector).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence that's dependent on a resource object whose lifetime is determined by the sequence usage duration.
- /// </summary>
- /// <typeparam name="TSource">Source element type.</typeparam>
- /// <typeparam name="TResource">Resource type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="resourceFactory">Resource factory function.</param>
- /// <param name="enumerableFactory">Enumerable factory function, having access to the obtained resource.</param>
- /// <returns>Sequence whose use controls the lifetime of the associated obtained resource.</returns>
- public static IQueryable<TSource> Using<TSource, TResource>(this IQueryProvider provider, Expression<Func<TResource>> resourceFactory, Expression<Func<TResource, IEnumerable<TSource>>> enumerableFactory) where TResource : IDisposable
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (resourceFactory == null)
- {
- throw new ArgumentNullException(nameof(resourceFactory));
- }
- if (enumerableFactory == null)
- {
- throw new ArgumentNullException(nameof(enumerableFactory));
- }
- return provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Using<TSource, TResource>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TResource)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- resourceFactory,
- enumerableFactory
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TSource> Using<TSource, TResource>(Func<TResource> resourceFactory, Func<TResource, IEnumerable<TSource>> enumerableFactory) where TResource : IDisposable
- {
- return EnumerableEx.Using(resourceFactory, enumerableFactory).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence by repeating the given value infinitely.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="value">Value to repeat in the resulting sequence.</param>
- /// <returns>Sequence repeating the given value infinitely.</returns>
- public static IEnumerable<TResult> Repeat<TResult>(this IQueryProvider provider, TResult value)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Repeat<TResult>(default, default(TResult))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- Expression.Constant(value, typeof(TResult))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Repeat<TResult>(TResult value)
- {
- return EnumerableEx.Repeat(value).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that corresponds to the source sequence, concatenating it with the sequence resulting from calling an exception handler function in case of an error.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TException">Exception type to catch.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="handler">Handler to invoke when an exception of the specified type occurs.</param>
- /// <returns>Source sequence, concatenated with an exception handler result sequence in case of an error.</returns>
- public static IQueryable<TSource> Catch<TSource, TException>(this IQueryable<TSource> source, Expression<Func<TException, IEnumerable<TSource>>> handler)
- where TException : Exception
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (handler == null)
- {
- throw new ArgumentNullException(nameof(handler));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Catch<TSource, TException>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TException)),
- #endif
- source.Expression,
- handler
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Catch<TSource, TException>(IEnumerable<TSource> source, Func<TException, IEnumerable<TSource>> handler)
- where TException : Exception
- {
- return EnumerableEx.Catch(source, handler);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence by concatenating source sequences until a source sequence completes successfully.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="sources">Source sequences.</param>
- /// <returns>Sequence that continues to concatenate source sequences while errors occur.</returns>
- public static IQueryable<TSource> Catch<TSource>(this IQueryable<IEnumerable<TSource>> sources)
- {
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return sources.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Catch<TSource>(default(IQueryable<IEnumerable<TSource>>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- sources.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Catch<TSource>(IEnumerable<IEnumerable<TSource>> sources)
- {
- return EnumerableEx.Catch(sources);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence by concatenating source sequences until a source sequence completes successfully.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="sources">Source sequences.</param>
- /// <returns>Sequence that continues to concatenate source sequences while errors occur.</returns>
- public static IQueryable<TSource> Catch<TSource>(this IQueryProvider provider, params IEnumerable<TSource>[] sources)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Catch<TSource>(default, default(IEnumerable<TSource>[]))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- GetSourceExpression(sources)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TSource> Catch<TSource>(params IEnumerable<TSource>[] sources)
- {
- return EnumerableEx.Catch(sources).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that returns the elements of the first sequence, switching to the second in case of an error.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="first">First sequence.</param>
- /// <param name="second">Second sequence, concatenated to the result in case the first sequence completes exceptionally.</param>
- /// <returns>The first sequence, followed by the second sequence in case an error is produced.</returns>
- public static IQueryable<TSource> Catch<TSource>(this IQueryable<TSource> first, IEnumerable<TSource> second)
- {
- if (first == null)
- {
- throw new ArgumentNullException(nameof(first));
- }
- if (second == null)
- {
- throw new ArgumentNullException(nameof(second));
- }
- return first.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Catch<TSource>(default(IQueryable<TSource>), default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- first.Expression,
- GetSourceExpression(second)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Catch<TSource>(IEnumerable<TSource> first, IEnumerable<TSource> second)
- {
- return EnumerableEx.Catch(first, second);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence whose termination or disposal of an enumerator causes a finally action to be executed.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="finallyAction">Action to run upon termination of the sequence, or when an enumerator is disposed.</param>
- /// <returns>Source sequence with guarantees on the invocation of the finally action.</returns>
- public static IQueryable<TSource> Finally<TSource>(this IQueryable<TSource> source, Expression<Action> finallyAction)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (finallyAction == null)
- {
- throw new ArgumentNullException(nameof(finallyAction));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Finally<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- finallyAction
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Finally<TSource>(IEnumerable<TSource> source, Action finallyAction)
- {
- return EnumerableEx.Finally(source, finallyAction);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that concatenates both given sequences, regardless of whether an error occurs.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="first">First sequence.</param>
- /// <param name="second">Second sequence.</param>
- /// <returns>Sequence concatenating the elements of both sequences, ignoring errors.</returns>
- public static IQueryable<TSource> OnErrorResumeNext<TSource>(this IQueryable<TSource> first, IEnumerable<TSource> second)
- {
- if (first == null)
- {
- throw new ArgumentNullException(nameof(first));
- }
- if (second == null)
- {
- throw new ArgumentNullException(nameof(second));
- }
- return first.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.OnErrorResumeNext<TSource>(default(IQueryable<TSource>), default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- first.Expression,
- GetSourceExpression(second)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> OnErrorResumeNext<TSource>(IEnumerable<TSource> first, IEnumerable<TSource> second)
- {
- return EnumerableEx.OnErrorResumeNext(first, second);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that concatenates the given sequences, regardless of whether an error occurs in any of the sequences.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="sources">Source sequences.</param>
- /// <returns>Sequence concatenating the elements of the given sequences, ignoring errors.</returns>
- public static IEnumerable<TSource> OnErrorResumeNext<TSource>(this IQueryProvider provider, params IEnumerable<TSource>[] sources)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.OnErrorResumeNext<TSource>(default, default(IEnumerable<TSource>[]))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- GetSourceExpression(sources)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TSource> OnErrorResumeNext<TSource>(params IEnumerable<TSource>[] sources)
- {
- return EnumerableEx.OnErrorResumeNext(sources).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that concatenates the given sequences, regardless of whether an error occurs in any of the sequences.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="sources">Source sequences.</param>
- /// <returns>Sequence concatenating the elements of the given sequences, ignoring errors.</returns>
- public static IQueryable<TSource> OnErrorResumeNext<TSource>(this IQueryable<IEnumerable<TSource>> sources)
- {
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return sources.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.OnErrorResumeNext<TSource>(default(IQueryable<IEnumerable<TSource>>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- sources.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> OnErrorResumeNext<TSource>(IEnumerable<IEnumerable<TSource>> sources)
- {
- return EnumerableEx.OnErrorResumeNext(sources);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that retries enumerating the source sequence as long as an error occurs.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <returns>Sequence concatenating the results of the source sequence as long as an error occurs.</returns>
- public static IQueryable<TSource> Retry<TSource>(this IQueryable<TSource> source)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Retry<TSource>(default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Retry<TSource>(IEnumerable<TSource> source)
- {
- return EnumerableEx.Retry(source);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Creates a sequence that retries enumerating the source sequence as long as an error occurs, with the specified maximum number of retries.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="retryCount">Maximum number of retries.</param>
- /// <returns>Sequence concatenating the results of the source sequence as long as an error occurs.</returns>
- public static IQueryable<TSource> Retry<TSource>(this IQueryable<TSource> source, int retryCount)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Retry<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(retryCount, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Retry<TSource>(IEnumerable<TSource> source, int retryCount)
- {
- return EnumerableEx.Retry(source, retryCount);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates an enumerable sequence by repeating a source sequence as long as the given loop condition holds.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="condition">Loop condition.</param>
- /// <param name="source">Sequence to repeat while the condition evaluates true.</param>
- /// <returns>Sequence generated by repeating the given sequence while the condition evaluates to true.</returns>
- public static IQueryable<TResult> While<TResult>(this IQueryProvider provider, Expression<Func<bool>> condition, IEnumerable<TResult> source)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (condition == null)
- {
- throw new ArgumentNullException(nameof(condition));
- }
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.While<TResult>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- condition,
- GetSourceExpression(source)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> While<TResult>(Func<bool> condition, IEnumerable<TResult> source)
- {
- return EnumerableEx.While(condition, source).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns an enumerable sequence based on the evaluation result of the given condition.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="condition">Condition to evaluate.</param>
- /// <param name="thenSource">Sequence to return in case the condition evaluates true.</param>
- /// <param name="elseSource">Sequence to return in case the condition evaluates false.</param>
- /// <returns>Either of the two input sequences based on the result of evaluating the condition.</returns>
- public static IQueryable<TResult> If<TResult>(this IQueryProvider provider, Expression<Func<bool>> condition, IEnumerable<TResult> thenSource, IEnumerable<TResult> elseSource)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (condition == null)
- {
- throw new ArgumentNullException(nameof(condition));
- }
- if (thenSource == null)
- {
- throw new ArgumentNullException(nameof(thenSource));
- }
- if (elseSource == null)
- {
- throw new ArgumentNullException(nameof(elseSource));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.If<TResult>(default, default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- condition,
- GetSourceExpression(thenSource),
- GetSourceExpression(elseSource)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> If<TResult>(Func<bool> condition, IEnumerable<TResult> thenSource, IEnumerable<TResult> elseSource)
- {
- return EnumerableEx.If(condition, thenSource, elseSource).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns an enumerable sequence if the evaluation result of the given condition is true, otherwise returns an empty sequence.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="condition">Condition to evaluate.</param>
- /// <param name="thenSource">Sequence to return in case the condition evaluates true.</param>
- /// <returns>The given input sequence if the condition evaluates true; otherwise, an empty sequence.</returns>
- public static IQueryable<TResult> If<TResult>(this IQueryProvider provider, Expression<Func<bool>> condition, IEnumerable<TResult> thenSource)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (condition == null)
- {
- throw new ArgumentNullException(nameof(condition));
- }
- if (thenSource == null)
- {
- throw new ArgumentNullException(nameof(thenSource));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.If<TResult>(default, default(Expression<Func<bool>>), default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- condition,
- GetSourceExpression(thenSource)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> If<TResult>(Func<bool> condition, IEnumerable<TResult> thenSource)
- {
- return EnumerableEx.If(condition, thenSource).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates an enumerable sequence by repeating a source sequence as long as the given loop postcondition holds.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="source">Source sequence to repeat while the condition evaluates true.</param>
- /// <param name="condition">Loop condition.</param>
- /// <returns>Sequence generated by repeating the given sequence until the condition evaluates to false.</returns>
- public static IQueryable<TResult> DoWhile<TResult>(this IQueryable<TResult> source, Expression<Func<bool>> condition)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (condition == null)
- {
- throw new ArgumentNullException(nameof(condition));
- }
- return source.Provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.DoWhile<TResult>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- source.Expression,
- condition
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TResult> DoWhile<TResult>(IEnumerable<TResult> source, Func<bool> condition)
- {
- return EnumerableEx.DoWhile(source, condition);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns a sequence from a dictionary based on the result of evaluating a selector function.
- /// </summary>
- /// <typeparam name="TValue">Type of the selector value.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="selector">Selector function used to pick a sequence from the given sources.</param>
- /// <param name="sources">Dictionary mapping selector values onto resulting sequences.</param>
- /// <returns>The source sequence corresponding with the evaluated selector value; otherwise, an empty sequence.</returns>
- public static IQueryable<TResult> Case<TValue, TResult>(this IQueryProvider provider, Expression<Func<TValue>> selector, IDictionary<TValue, IEnumerable<TResult>> sources)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Case<TValue, TResult>(default, default, default(IDictionary<TValue, IEnumerable<TResult>>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TValue), typeof(TResult)),
- #endif
- selector,
- Expression.Constant(sources, typeof(IDictionary<TValue, IEnumerable<TResult>>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Case<TValue, TResult>(Func<TValue> selector, IDictionary<TValue, IEnumerable<TResult>> sources)
- {
- return EnumerableEx.Case(selector, sources).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns a sequence from a dictionary based on the result of evaluating a selector function, also specifying a default sequence.
- /// </summary>
- /// <typeparam name="TValue">Type of the selector value.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="selector">Selector function used to pick a sequence from the given sources.</param>
- /// <param name="sources">Dictionary mapping selector values onto resulting sequences.</param>
- /// <param name="defaultSource">Default sequence to return in case there's no corresponding source for the computed selector value.</param>
- /// <returns>The source sequence corresponding with the evaluated selector value; otherwise, the default source.</returns>
- public static IQueryable<TResult> Case<TValue, TResult>(this IQueryProvider provider, Expression<Func<TValue>> selector, IDictionary<TValue, IEnumerable<TResult>> sources, IEnumerable<TResult> defaultSource)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- if (defaultSource == null)
- {
- throw new ArgumentNullException(nameof(defaultSource));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Case<TValue, TResult>(default, default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TValue), typeof(TResult)),
- #endif
- selector,
- Expression.Constant(sources, typeof(IDictionary<TValue, IEnumerable<TResult>>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Case<TValue, TResult>(Func<TValue> selector, IDictionary<TValue, IEnumerable<TResult>> sources, IEnumerable<TResult> defaultSource)
- {
- return EnumerableEx.Case(selector, sources, defaultSource).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence by enumerating a source sequence, mapping its elements on result sequences, and concatenating those sequences.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="source">Source sequence.</param>
- /// <param name="resultSelector">Result selector to evaluate for each iteration over the source.</param>
- /// <returns>Sequence concatenating the inner sequences that result from evaluating the result selector on elements from the source.</returns>
- public static IQueryable<TResult> For<TSource, TResult>(this IQueryProvider provider, IEnumerable<TSource> source, Expression<Func<TSource, IEnumerable<TResult>>> resultSelector)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (resultSelector == null)
- {
- throw new ArgumentNullException(nameof(resultSelector));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.For<TSource, TResult>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TResult)),
- #endif
- GetSourceExpression(source),
- resultSelector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> For<TSource, TResult>(IEnumerable<TSource> source, Func<TSource, IEnumerable<TResult>> resultSelector)
- {
- return EnumerableEx.For(source, resultSelector).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Concatenates the input sequences.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="sources">Source sequences.</param>
- /// <returns>Sequence with the elements of the source sequences concatenated.</returns>
- public static IQueryable<TSource> Concat<TSource>(this IQueryable<IEnumerable<TSource>> sources)
- {
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return sources.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Concat<TSource>(default(IQueryable<IEnumerable<TSource>>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- GetSourceExpression(sources)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Concat<TSource>(IEnumerable<IEnumerable<TSource>> sources)
- {
- return EnumerableEx.Concat(sources);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Concatenates the input sequences.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="sources">Source sequences.</param>
- /// <returns>Sequence with the elements of the source sequences concatenated.</returns>
- public static IQueryable<TSource> Concat<TSource>(this IQueryProvider provider, params IEnumerable<TSource>[] sources)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- if (sources == null)
- {
- throw new ArgumentNullException(nameof(sources));
- }
- return provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Concat<TSource>(default, default(IEnumerable<TSource>[]))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- GetSourceExpression(sources)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TSource> Concat<TSource>(params IEnumerable<TSource>[] sources)
- {
- return EnumerableEx.Concat(sources).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Projects each element of a sequence to an given sequence and flattens the resulting sequences into one sequence.
- /// </summary>
- /// <typeparam name="TSource">First source sequence element type.</typeparam>
- /// <typeparam name="TOther">Second source sequence element type.</typeparam>
- /// <param name="source">A sequence of values to project.</param>
- /// <param name="other">Inner sequence each source sequence element is projected onto.</param>
- /// <returns>Sequence flattening the sequences that result from projecting elements in the source sequence.</returns>
- public static IQueryable<TOther> SelectMany<TSource, TOther>(this IQueryable<TSource> source, IEnumerable<TOther> other)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (other == null)
- {
- throw new ArgumentNullException(nameof(other));
- }
- return source.Provider.CreateQuery<TOther>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.SelectMany<TSource, TOther>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TOther)),
- #endif
- source.Expression,
- GetSourceExpression(other)
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TOther> SelectMany<TSource, TOther>(IEnumerable<TSource> source, IEnumerable<TOther> other)
- {
- return EnumerableEx.SelectMany(source, other);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Hides the enumerable sequence object identity.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <returns>Enumerable sequence with the same behavior as the original, but hiding the source object identity.</returns>
- /// <remarks>AsQueryable doesn't hide the object identity, and simply acts as a cast to the IQueryable<TSource> interface.</remarks>
- public static IQueryable<TSource> Hide<TSource>(this IQueryable<TSource> source)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Hide<TSource>(default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Hide<TSource>(IEnumerable<TSource> source)
- {
- return EnumerableEx.Hide(source);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Lazily invokes an action for each value in the sequence.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="onNext">Action to invoke for each element.</param>
- /// <returns>Sequence exhibiting the specified side-effects upon enumeration.</returns>
- public static IQueryable<TSource> Do<TSource>(this IQueryable<TSource> source, Expression<Action<TSource>> onNext)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (onNext == null)
- {
- throw new ArgumentNullException(nameof(onNext));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Do<TSource>(default, default(Expression<Action<TSource>>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- onNext
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Do<TSource>(IEnumerable<TSource> source, Action<TSource> onNext)
- {
- return EnumerableEx.Do(source, onNext);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Lazily invokes an action for each value in the sequence, and executes an action for successful termination.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="onNext">Action to invoke for each element.</param>
- /// <param name="onCompleted">Action to invoke on successful termination of the sequence.</param>
- /// <returns>Sequence exhibiting the specified side-effects upon enumeration.</returns>
- public static IQueryable<TSource> Do<TSource>(this IQueryable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action> onCompleted)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (onNext == null)
- {
- throw new ArgumentNullException(nameof(onNext));
- }
- if (onCompleted == null)
- {
- throw new ArgumentNullException(nameof(onCompleted));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Do<TSource>(default, default, default(Expression<Action>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- onNext,
- onCompleted
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Do<TSource>(IEnumerable<TSource> source, Action<TSource> onNext, Action onCompleted)
- {
- return EnumerableEx.Do(source, onNext, onCompleted);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Lazily invokes an action for each value in the sequence, and executes an action upon exceptional termination.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="onNext">Action to invoke for each element.</param>
- /// <param name="onError">Action to invoke on exceptional termination of the sequence.</param>
- /// <returns>Sequence exhibiting the specified side-effects upon enumeration.</returns>
- public static IQueryable<TSource> Do<TSource>(this IQueryable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action<Exception>> onError)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (onNext == null)
- {
- throw new ArgumentNullException(nameof(onNext));
- }
- if (onError == null)
- {
- throw new ArgumentNullException(nameof(onError));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Do<TSource>(default, default, default(Expression<Action<Exception>>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- onNext,
- onError
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Do<TSource>(IEnumerable<TSource> source, Action<TSource> onNext, Action<Exception> onError)
- {
- return EnumerableEx.Do(source, onNext, onError);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Lazily invokes an action for each value in the sequence, and executes an action upon successful or exceptional termination.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="onNext">Action to invoke for each element.</param>
- /// <param name="onError">Action to invoke on exceptional termination of the sequence.</param>
- /// <param name="onCompleted">Action to invoke on successful termination of the sequence.</param>
- /// <returns>Sequence exhibiting the specified side-effects upon enumeration.</returns>
- public static IQueryable<TSource> Do<TSource>(this IQueryable<TSource> source, Expression<Action<TSource>> onNext, Expression<Action<Exception>> onError, Expression<Action> onCompleted)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (onNext == null)
- {
- throw new ArgumentNullException(nameof(onNext));
- }
- if (onError == null)
- {
- throw new ArgumentNullException(nameof(onError));
- }
- if (onCompleted == null)
- {
- throw new ArgumentNullException(nameof(onCompleted));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Do<TSource>(default, default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- onNext,
- onError,
- onCompleted
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Do<TSource>(IEnumerable<TSource> source, Action<TSource> onNext, Action<Exception> onError, Action onCompleted)
- {
- return EnumerableEx.Do(source, onNext, onError, onCompleted);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Lazily invokes observer methods for each value in the sequence, and upon successful or exceptional termination.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="observer">Observer to invoke notification calls on.</param>
- /// <returns>Sequence exhibiting the side-effects of observer method invocation upon enumeration.</returns>
- public static IQueryable<TSource> Do<TSource>(this IQueryable<TSource> source, IObserver<TSource> observer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (observer == null)
- {
- throw new ArgumentNullException(nameof(observer));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Do<TSource>(default, default(IObserver<TSource>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(observer, typeof(IObserver<TSource>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Do<TSource>(IEnumerable<TSource> source, IObserver<TSource> observer)
- {
- return EnumerableEx.Do(source, observer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence of non-overlapping adjacent buffers over the source sequence.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="count">Number of elements for allocated buffers.</param>
- /// <returns>Sequence of buffers containing source sequence elements.</returns>
- public static IQueryable<IList<TSource>> Buffer<TSource>(this IQueryable<TSource> source, int count)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<IList<TSource>>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Buffer<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(count, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<IList<TSource>> Buffer<TSource>(IEnumerable<TSource> source, int count)
- {
- return EnumerableEx.Buffer(source, count);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence of buffers over the source sequence, with specified length and possible overlap.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="count">Number of elements for allocated buffers.</param>
- /// <param name="skip">Number of elements to skip between the start of consecutive buffers.</param>
- /// <returns>Sequence of buffers containing source sequence elements.</returns>
- public static IQueryable<IList<TSource>> Buffer<TSource>(this IQueryable<TSource> source, int count, int skip)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<IList<TSource>>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Buffer<TSource>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(count, typeof(int)),
- Expression.Constant(skip, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<IList<TSource>> Buffer<TSource>(IEnumerable<TSource> source, int count, int skip)
- {
- return EnumerableEx.Buffer(source, count, skip);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Ignores all elements in the source sequence.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <returns>Source sequence without its elements.</returns>
- public static IQueryable<TSource> IgnoreElements<TSource>(this IQueryable<TSource> source)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.IgnoreElements<TSource>(default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> IgnoreElements<TSource>(IEnumerable<TSource> source)
- {
- return EnumerableEx.IgnoreElements(source);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns elements with a distinct key value by using the default equality comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector.</param>
- /// <returns>Sequence that contains the elements from the source sequence with distinct key values.</returns>
- public static IQueryable<TSource> Distinct<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Distinct<TSource, TKey>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Distinct<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
- {
- return EnumerableEx.Distinct(source, keySelector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns elements with a distinct key value by using the specified equality comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector.</param>
- /// <param name="comparer">Comparer used to compare key values.</param>
- /// <returns>Sequence that contains the elements from the source sequence with distinct key values.</returns>
- public static IQueryable<TSource> Distinct<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector, IEqualityComparer<TKey> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Distinct<TSource, TKey>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector,
- Expression.Constant(comparer, typeof(IEqualityComparer<TKey>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Distinct<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
- {
- return EnumerableEx.Distinct(source, keySelector, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns consecutive distinct elements by using the default equality comparer to compare values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <returns>Sequence without adjacent non-distinct elements.</returns>
- public static IQueryable<TSource> DistinctUntilChanged<TSource>(this IQueryable<TSource> source)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.DistinctUntilChanged<TSource>(default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> DistinctUntilChanged<TSource>(IEnumerable<TSource> source)
- {
- return EnumerableEx.DistinctUntilChanged(source);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns consecutive distinct elements by using the specified equality comparer to compare values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="comparer">Comparer used to compare values.</param>
- /// <returns>Sequence without adjacent non-distinct elements.</returns>
- public static IQueryable<TSource> DistinctUntilChanged<TSource>(this IQueryable<TSource> source, IEqualityComparer<TSource> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.DistinctUntilChanged<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(comparer, typeof(IEqualityComparer<TSource>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> DistinctUntilChanged<TSource>(IEnumerable<TSource> source, IEqualityComparer<TSource> comparer)
- {
- return EnumerableEx.DistinctUntilChanged(source, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns consecutive distinct elements based on a key value by using the specified equality comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector.</param>
- /// <returns>Sequence without adjacent non-distinct elements.</returns>
- public static IQueryable<TSource> DistinctUntilChanged<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.DistinctUntilChanged<TSource, TKey>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
- {
- return EnumerableEx.DistinctUntilChanged(source, keySelector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns consecutive distinct elements based on a key value by using the specified equality comparer to compare key values.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TKey">Key type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="keySelector">Key selector.</param>
- /// <param name="comparer">Comparer used to compare key values.</param>
- /// <returns>Sequence without adjacent non-distinct elements.</returns>
- public static IQueryable<TSource> DistinctUntilChanged<TSource, TKey>(this IQueryable<TSource> source, Expression<Func<TSource, TKey>> keySelector, IEqualityComparer<TKey> comparer)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (keySelector == null)
- {
- throw new ArgumentNullException(nameof(keySelector));
- }
- if (comparer == null)
- {
- throw new ArgumentNullException(nameof(comparer));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.DistinctUntilChanged<TSource, TKey>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TKey)),
- #endif
- source.Expression,
- keySelector,
- Expression.Constant(comparer, typeof(IEqualityComparer<TKey>))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(IEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
- {
- return EnumerableEx.DistinctUntilChanged(source, keySelector, comparer);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Expands the sequence by recursively applying a selector function.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="selector">Selector function to retrieve the next sequence to expand.</param>
- /// <returns>Sequence with results from the recursive expansion of the source sequence.</returns>
- public static IQueryable<TSource> Expand<TSource>(this IQueryable<TSource> source, Expression<Func<TSource, IEnumerable<TSource>>> selector)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (selector == null)
- {
- throw new ArgumentNullException(nameof(selector));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Expand<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- selector
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Expand<TSource>(IEnumerable<TSource> source, Func<TSource, IEnumerable<TSource>> selector)
- {
- return EnumerableEx.Expand(source, selector);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns the source sequence prefixed with the specified value.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="values">Values to prefix the sequence with.</param>
- /// <returns>Sequence starting with the specified prefix value, followed by the source sequence.</returns>
- public static IQueryable<TSource> StartWith<TSource>(this IQueryable<TSource> source, params TSource[] values)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.StartWith<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(values, typeof(TSource[]))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> StartWith<TSource>(IEnumerable<TSource> source, params TSource[] values)
- {
- return EnumerableEx.StartWith(source, values);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence of accumulated values by scanning the source sequence and applying an accumulator function.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <typeparam name="TAccumulate">Accumulation type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="seed">Accumulator seed value.</param>
- /// <param name="accumulator">Accumulation function to apply to the current accumulation value and each element of the sequence.</param>
- /// <returns>Sequence with all intermediate accumulation values resulting from scanning the sequence.</returns>
- public static IQueryable<TAccumulate> Scan<TSource, TAccumulate>(this IQueryable<TSource> source, TAccumulate seed, Expression<Func<TAccumulate, TSource, TAccumulate>> accumulator)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (accumulator == null)
- {
- throw new ArgumentNullException(nameof(accumulator));
- }
- return source.Provider.CreateQuery<TAccumulate>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Scan<TSource, TAccumulate>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource), typeof(TAccumulate)),
- #endif
- source.Expression,
- Expression.Constant(seed, typeof(TAccumulate)),
- accumulator
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TAccumulate> Scan<TSource, TAccumulate>(IEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator)
- {
- return EnumerableEx.Scan(source, seed, accumulator);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence of accumulated values by scanning the source sequence and applying an accumulator function.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="accumulator">Accumulation function to apply to the current accumulation value and each element of the sequence.</param>
- /// <returns>Sequence with all intermediate accumulation values resulting from scanning the sequence.</returns>
- public static IQueryable<TSource> Scan<TSource>(this IQueryable<TSource> source, Expression<Func<TSource, TSource, TSource>> accumulator)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- if (accumulator == null)
- {
- throw new ArgumentNullException(nameof(accumulator));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Scan<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- accumulator
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Scan<TSource>(IEnumerable<TSource> source, Func<TSource, TSource, TSource> accumulator)
- {
- return EnumerableEx.Scan(source, accumulator);
- }
- #pragma warning restore 1591
- #if !(REFERENCE_ASSEMBLY && (NETCOREAPP2_0 || NETSTANDARD2_1))
- /// <summary>
- /// Returns a specified number of contiguous elements from the end of the sequence.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="count">The number of elements to take from the end of the sequence.</param>
- /// <returns>Sequence with the specified number of elements counting from the end of the source sequence.</returns>
- public static IQueryable<TSource> TakeLast<TSource>(this IQueryable<TSource> source, int count)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.TakeLast<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(count, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> TakeLast<TSource>(IEnumerable<TSource> source, int count)
- {
- return EnumerableEx.TakeLast(source, count);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Bypasses a specified number of contiguous elements from the end of the sequence and returns the remaining elements.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="count">The number of elements to skip from the end of the sequence before returning the remaining elements.</param>
- /// <returns>Sequence bypassing the specified number of elements counting from the end of the source sequence.</returns>
- public static IQueryable<TSource> SkipLast<TSource>(this IQueryable<TSource> source, int count)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.SkipLast<TSource>(default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(count, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> SkipLast<TSource>(IEnumerable<TSource> source, int count)
- {
- return EnumerableEx.SkipLast(source, count);
- }
- #pragma warning restore 1591
- #endif
- /// <summary>
- /// Repeats and concatenates the source sequence infinitely.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <returns>Sequence obtained by concatenating the source sequence to itself infinitely.</returns>
- public static IQueryable<TSource> Repeat<TSource>(this IQueryable<TSource> source)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Repeat<TSource>(default(IQueryable<TSource>))),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Repeat<TSource>(IEnumerable<TSource> source)
- {
- return EnumerableEx.Repeat(source);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Repeats and concatenates the source sequence the given number of times.
- /// </summary>
- /// <typeparam name="TSource">Source sequence element type.</typeparam>
- /// <param name="source">Source sequence.</param>
- /// <param name="count">Number of times to repeat the source sequence.</param>
- /// <returns>Sequence obtained by concatenating the source sequence to itself the specified number of times.</returns>
- public static IQueryable<TSource> Repeat<TSource>(this IQueryable<TSource> source, int count)
- {
- if (source == null)
- {
- throw new ArgumentNullException(nameof(source));
- }
- return source.Provider.CreateQuery<TSource>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Repeat<TSource>(default(IQueryable<TSource>), default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TSource)),
- #endif
- source.Expression,
- Expression.Constant(count, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static IEnumerable<TSource> Repeat<TSource>(IEnumerable<TSource> source, int count)
- {
- return EnumerableEx.Repeat(source, count);
- }
- #pragma warning restore 1591
- /// <summary>
- /// Returns a sequence with no elements.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <returns>Sequence with no elements.</returns>
- public static IQueryable<TResult> Empty<TResult>(this IQueryProvider provider)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Empty<TResult>(default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Empty<TResult>()
- {
- return Enumerable.Empty<TResult>().AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence of integral numbers within a specified range.
- /// </summary>
- /// <param name="provider">Query provider.</param>
- /// <param name="start">The value of the first integer in the sequence.</param>
- /// <param name="count">The number of sequential integers to generate.</param>
- /// <returns>Sequence that contains a range of sequential integral numbers.</returns>
- public static IQueryable<int> Range(this IQueryProvider provider, int start, int count)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- return provider.CreateQuery<int>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Range(default, default, default)),
- #else
- (MethodInfo)MethodInfo.GetCurrentMethod(),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- Expression.Constant(start, typeof(int)),
- Expression.Constant(count, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<int> Range(int start, int count)
- {
- return Enumerable.Range(start, count).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Generates a sequence that contains one repeated value.
- /// </summary>
- /// <typeparam name="TResult">Result sequence element type.</typeparam>
- /// <param name="provider">Query provider.</param>
- /// <param name="element">The value to be repeated.</param>
- /// <param name="count">The number of times to repeat the value in the generated sequence.</param>
- /// <returns>Sequence that contains a repeated value.</returns>
- public static IQueryable<TResult> Repeat<TResult>(this IQueryProvider provider, TResult element, int count)
- {
- if (provider == null)
- {
- throw new ArgumentNullException(nameof(provider));
- }
- return provider.CreateQuery<TResult>(
- Expression.Call(
- null,
- #if CRIPPLED_REFLECTION
- InfoOf(() => QueryableEx.Repeat<TResult>(default, default, default)),
- #else
- ((MethodInfo)MethodInfo.GetCurrentMethod()).MakeGenericMethod(typeof(TResult)),
- #endif
- Expression.Constant(provider, typeof(IQueryProvider)),
- Expression.Constant(element, typeof(TResult)),
- Expression.Constant(count, typeof(int))
- )
- );
- }
- #pragma warning disable 1591
- [EditorBrowsable(EditorBrowsableState.Never)]
- public static /*!*/IQueryable<TResult> Repeat<TResult>(TResult element, int count)
- {
- return EnumerableEx.Repeat<TResult>(element, count).AsQueryable();
- }
- #pragma warning restore 1591
- /// <summary>
- /// Gets the local Queryable provider.
- /// </summary>
- public static IQueryProvider Provider
- {
- get
- {
- return new QueryProviderShim();
- }
- }
- private class QueryProviderShim : IQueryProvider
- {
- public IQueryable<TElement> CreateQuery<TElement>(Expression expression)
- {
- var provider = new TElement[0].AsQueryable().Provider;
- var res = Redir(expression);
- return provider.CreateQuery<TElement>(res);
- }
- public IQueryable CreateQuery(Expression expression)
- {
- return CreateQuery<object>(expression);
- }
- public TResult Execute<TResult>(Expression expression)
- {
- var provider = new TResult[0].AsQueryable().Provider;
- var res = Redir(expression);
- return provider.Execute<TResult>(res);
- }
- public object Execute(Expression expression)
- {
- return Execute<object>(expression);
- }
- private static Expression Redir(Expression expression)
- {
- if (expression is MethodCallExpression mce && mce.Method.DeclaringType == typeof(QueryableEx))
- {
- if (mce.Arguments.Count >= 1 && typeof(IQueryProvider).IsAssignableFrom(mce.Arguments[0].Type))
- {
- if (mce.Arguments[0] is ConstantExpression ce)
- {
- if (ce.Value is QueryProviderShim)
- {
- var targetType = typeof(QueryableEx);
- var method = mce.Method;
- var methods = GetMethods(targetType);
- var arguments = mce.Arguments.Skip(1).ToList();
- //
- // From all the operators with the method's name, find the one that matches all arguments.
- //
- var typeArgs = method.IsGenericMethod ? method.GetGenericArguments() : null;
- var targetMethod = methods[method.Name].FirstOrDefault(candidateMethod => ArgsMatch(candidateMethod, arguments, typeArgs));
- if (targetMethod == null)
- {
- throw new InvalidOperationException(string.Format(CultureInfo.CurrentCulture, "There is no method '{0}' on type '{1}' that matches the specified arguments", method.Name, targetType.Name));
- }
- //
- // Restore generic arguments.
- //
- if (typeArgs != null)
- {
- targetMethod = targetMethod.MakeGenericMethod(typeArgs);
- }
- //
- // Finally, we need to deal with mismatches on Expression<Func<...>> versus Func<...>.
- //
- var parameters = targetMethod.GetParameters();
- for (int i = 0, n = parameters.Length; i < n; i++)
- {
- arguments[i] = Unquote(arguments[i]);
- }
- //
- // Emit a new call to the discovered target method.
- //
- return Expression.Call(null, targetMethod, arguments);
- }
- }
- }
- }
- return expression;
- }
- private static ILookup<string, MethodInfo> GetMethods(Type type)
- {
- return type.GetMethods(BindingFlags.Static | BindingFlags.Public).ToLookup(m => m.Name);
- }
- private static bool ArgsMatch(MethodInfo method, IList<Expression> arguments, Type[] typeArgs)
- {
- //
- // Number of parameters should match. Notice we've sanitized IQueryProvider "this"
- // parameters first (see Redir).
- //
- var parameters = method.GetParameters();
- if (parameters.Length != arguments.Count)
- {
- return false;
- }
- //
- // Genericity should match too.
- //
- if (!method.IsGenericMethod && typeArgs != null && typeArgs.Length > 0)
- {
- return false;
- }
- //
- // Reconstruct the generic method if needed.
- //
- if (method.IsGenericMethodDefinition)
- {
- if (typeArgs == null)
- {
- return false;
- }
- if (method.GetGenericArguments().Length != typeArgs.Length)
- {
- return false;
- }
- var result = method.MakeGenericMethod(typeArgs);
- parameters = result.GetParameters();
- }
- //
- // Check compatibility for the parameter types.
- //
- for (int i = 0, n = arguments.Count; i < n; i++)
- {
- var parameterType = parameters[i].ParameterType;
- var argument = arguments[i];
- //
- // For operators that take a function (like Where, Select), we'll be faced
- // with a quoted argument and a discrepancy between Expression<Func<...>>
- // and the underlying Func<...>.
- //
- if (!parameterType.IsAssignableFrom(argument.Type))
- {
- argument = Unquote(argument);
- if (!parameterType.IsAssignableFrom(argument.Type))
- {
- return false;
- }
- }
- }
- return true;
- }
- private static Expression Unquote(Expression expression)
- {
- //
- // Get rid of all outer quotes around an expression.
- //
- while (expression.NodeType == ExpressionType.Quote)
- {
- expression = ((UnaryExpression)expression).Operand;
- }
- return expression;
- }
- }
- internal static Expression GetSourceExpression<TSource>(IEnumerable<TSource> source)
- {
- if (source is IQueryable<TSource> q)
- {
- return q.Expression;
- }
- return Expression.Constant(source, typeof(IEnumerable<TSource>));
- }
- internal static Expression GetSourceExpression<TSource>(IEnumerable<TSource>[] sources)
- {
- return Expression.NewArrayInit(
- typeof(IEnumerable<TSource>),
- sources.Select(source => GetSourceExpression(source))
- );
- }
- internal static MethodInfo InfoOf<R>(Expression<Func<R>> f)
- {
- return ((MethodCallExpression)f.Body).Method;
- }
- }
- }
|