LinqExtensions class¶
Defined in
Namespace: ReactiveUI.Primitives.Reactive
Assembly: ReactiveUI.Primitives.Reactive.dll
Full name: ReactiveUI.Primitives.Reactive.LinqExtensions
Modifiers: public static
Summary¶
System.Reactive / LINQ familiar names for the Primitives operator vocabulary. Each method builds the same sink as
its Primitives-named counterpart directly, so the two names are interchangeable with identical behaviour and
allocation profile. Both name sets are fully supported.
Applies to
net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481
Methods¶
| Name | Summary |
|---|---|
| static Blend | |
| static DisposeWith | |
| static Buffer | |
| static BlendUnique | Concurrently merges the supplied sources and forwards only values that differ from the previously forwarded value, using the default equality comparer. Errors are forwarded from the... |
| static Choose | |
| static SwitchSelect | |
| static ToSignal | |
| static Race | |
| static Chain | |
| static SwitchTo | |
| static Unspark | |
| static Map | |
| static MapWith | |
| static Keep | |
| static KeepWith | |
| static Tap | |
| static TapWith | |
| static Fold | |
| static Reduce | |
| static Take | |
| static TakeUntil | |
| static Skip | |
| static Distinct | |
| static Unique | |
| static Spark | |
| static Pair | |
| static SyncLatest | |
| static Latch | |
| static Reattempt | |
| static Recover | |
| static Rescue | |
| static Resume | |
| static Shift | |
| static Expire | |
| static CollectList | |
| static CollectArray | |
| static KeepNotNull | |
| static KeepType | |
| static CastTo | |
| static ToObservable | |
| static Lead | |
| static Prepend | |
| static Append | |
| static AsObservable | |
| static ObserveOn | |
| static SubscribeOn | |
| static DelaySubscription | |
| static IgnoreValues | |
| static DefaultIfEmpty | |
| static DistinctBy | |
| static UniqueBy | |
| static TakeWhile | |
| static SkipWhile | |
| static Bind | |
| static FlatMap | |
| static FlatMapValues | |
| static Count | |
| static LongCount | |
| static Any | |
| static All | |
| static Contains | |
| static IsEmpty | |
| static DelayStart | |
| static Calm | |
| static Stabilize | |
| static Probe | |
| static Timestamp | |
| static TimeInterval | |
| static PairLatest | |
| static FuseLatest | |
| static ForkJoin | |
| static FirstAsync | |
| static FirstOrDefaultAsync | |
| static ToTask | |
| static LastAsync | |
| static LastOrDefaultAsync | |
| static CountAsync | |
| static AnyAsync | |
| static CollectArrayAsync | |
| static ToArray | |
| static ToArrayAsync | |
| static CollectListAsync | |
| static ToList | |
| static ToListAsync | |
| static Merge | |
| static Concat | |
| static Amb | |
| static Switch | |
| static Dematerialize | |
| static Do | |
| static Synchronize | |
| static DoWith | |
| static Scan | |
| static Aggregate | |
| static DistinctUntilChanged | |
| static DistinctUntilChangedBy | |
| static IgnoreElements | |
| static SelectMany | |
| static WhereNotNull | |
| static Zip | |
| static CombineLatest | |
| static WithLatestFrom | |
| static Delay | |
| static Timeout | |
| static Sample | |
| static Retry | |
| static Materialize | |
| static Select | |
| static SelectWith | |
| static Where | |
| static WhereWith |
Inherited members
Extension blocks¶
extension(IEnumerable> sources)¶
Blend
extension(IDisposable disposable)¶
DisposeWithDisposeWithDisposeWith
extension(IObservable source)¶
BufferBufferSelectSelectWithWhereWhereWith
extension(IObservable source)¶
Choose
extension(IObservable source)¶
SwitchSelect
extension(IObservable source)¶
MapMapWithKeepKeepWithTapTapWithFoldReduceTakeTakeUntilSkipDistinctDistinctUniqueUniqueSparkChainPairSyncLatestLatchReattemptRecoverRescueResumeShiftShiftExpireExpireCollectListCollectArrayToSignalLeadPrependPrependPrependAppendAsObservableObserveOnSubscribeOnDelaySubscriptionDelaySubscriptionTapIgnoreValuesDefaultIfEmptyDefaultIfEmptyDistinctByDistinctByUniqueByUniqueByTakeWhileSkipWhileBindFlatMapFlatMapFlatMapValuesCountCountLongCountLongCountAnyAnyAllContainsContainsIsEmptyDelayStartDelayStartCalmCalmStabilizeStabilizeProbeProbeTimestampTimestampTimeIntervalTimeIntervalPairLatestFuseLatestForkJoinFirstAsyncFirstOrDefaultAsyncFirstOrDefaultAsyncToTaskToTaskLastAsyncLastOrDefaultAsyncLastOrDefaultAsyncCountAsyncCountAsyncCountAsyncCountAsyncAnyAsyncAnyAsyncAnyAsyncAnyAsyncCollectArrayAsyncToArrayToArrayAsyncCollectListAsyncToListToListAsyncDoSynchronizeSynchronizeDoWithScanAggregateDistinctUntilChangedDistinctUntilChangedDistinctUntilChangedByDistinctUntilChangedByIgnoreElementsSelectManySelectManyConcat
extension(IObservable left)¶
ZipCombineLatestWithLatestFromDelayDelayTimeoutTimeoutSampleSampleRetryMaterialize
extension(IEnumerable values)¶
ToSignalToSignalToObservableToObservable
extension(IObservable> sources)¶
BlendRaceChainSwitchToMergeConcatAmbSwitch
extension(IObservable> source)¶
UnsparkDematerialize
extension(IObservable source)¶
KeepNotNullWhereNotNull
extension(IObservable source)¶
KeepTypeCastTo
extension(Task task)¶
ToTask