Skip to content

ReactiveExtensions class

Defined in

Namespace: ReactiveUI.Primitives.Extensions.Reactive Assembly: ReactiveUI.Primitives.Extensions.Reactive.dll Full name: ReactiveUI.Primitives.Extensions.Reactive.ReactiveExtensions Modifiers: public static

Summary

View source

Extension methods for Reactive objects.

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

NameSummary
static CombineLatestValuesAreAllFalse
static CombineLatestValuesAreAllTrue
static FromArray
static WithLimitedConcurrency
static ForEach
static CatchReturnUnit
static WhereIsNotNull
static AsSignal
static BufferUntilIdle
static CatchIgnore
static DetectStale
static Conflate
static Heartbeat
static LatestOrDefault
static LogErrors
static ObserveOnSafe
static ObserveOnIf
static SampleLatest
static ScanWithInitial
static Schedule
static OnErrorRetry
static TakeUntil
static SynchronizeSynchronous
static SubscribeSynchronous
static SwitchIfEmpty
static SynchronizeAsync
static SubscribeAsync
static CatchAndReturn
static RetryWithBackoff
static RetryWithDelay
static RetryForeverWithDelay
static RetryWithFixedDelay
static ReplayLastOnSubscribe
static ThrottleFirst
static ThrottleUntilTrue
static ThrottleOnScheduler
static ToHotTask
static ToHotValueTask
static ThrottleDistinct
static DebounceImmediate
static DebounceUntil
static SelectAsync
static SelectAsyncSequential
static SelectLatestAsync
static SelectAsyncConcurrent
static Pairwise
static Partition
static BufferUntilInactive
static WaitUntil
static DropIfBusy
static DoOnSubscribe
static DoOnDispose
static WhereSelect
static CatchReturn
static SelectConstant
static TrySelect
static SelectManyThen
static GetMax
static GetMin
static SkipWhileNull
static Shuffle
static Not
static WhereTrue
static WhereFalse
static BufferUntil
static Filter
static OnNext
static RunAll
static FirstMatchFromCandidates
static ScheduleSafe
static Using
static ToPropertyObservable
static SyncTimerSynchronized timer all instances of this with the same TimeSpan use the same timer.
static StartInvokes the action asynchronously surfacing the result through a RxVoid observable.
static WhileWhile construct.
static ToReadOnlyBehaviorBuilds a current-value subject pair: a read-only observable and the push-side observer.
Inherited members

Extension blocks

extension(IEnumerable> sources)

  • CombineLatestValuesAreAllFalse
  • CombineLatestValuesAreAllTrue

extension(IEnumerable source)

  • FromArray
  • FromArray

extension(IEnumerable> taskFunctions)

  • WithLimitedConcurrency

extension(IObservable> source)

  • ForEach
  • ForEach

extension(IObservable source)

  • CatchReturnUnit

extension(IObservable source)

  • WhereIsNotNull
  • AsSignal
  • BufferUntilIdle
  • BufferUntilIdle
  • CatchIgnore
  • DetectStale
  • Conflate
  • Heartbeat
  • LatestOrDefault
  • LogErrors
  • ObserveOnSafe
  • ObserveOnIf
  • ObserveOnIf
  • ObserveOnIf
  • ObserveOnIf
  • SampleLatest
  • ScanWithInitial
  • Schedule
  • Schedule
  • Schedule
  • Schedule
  • Schedule
  • Schedule
  • OnErrorRetry
  • OnErrorRetry
  • OnErrorRetry
  • OnErrorRetry
  • OnErrorRetry
  • OnErrorRetry
  • TakeUntil
  • SynchronizeSynchronous
  • SubscribeSynchronous
  • SubscribeSynchronous
  • SubscribeSynchronous
  • SubscribeSynchronous
  • SwitchIfEmpty
  • SynchronizeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • CatchAndReturn
  • CatchAndReturn
  • RetryWithBackoff
  • RetryWithBackoff
  • RetryWithDelay
  • RetryForeverWithDelay
  • RetryWithFixedDelay
  • ReplayLastOnSubscribe
  • ThrottleFirst
  • ThrottleFirst
  • ThrottleUntilTrue
  • ThrottleOnScheduler
  • ToHotTask
  • ToHotValueTask
  • ThrottleDistinct
  • ThrottleDistinct
  • DebounceImmediate
  • DebounceImmediate
  • DebounceUntil
  • DebounceUntil
  • SelectAsync
  • SelectAsync
  • SelectAsyncSequential
  • SelectLatestAsync
  • SelectAsyncConcurrent
  • Pairwise
  • Partition
  • BufferUntilInactive
  • BufferUntilInactive
  • WaitUntil
  • DropIfBusy
  • DoOnSubscribe
  • DoOnDispose
  • WhereSelect
  • CatchReturn
  • SelectConstant
  • TrySelect
  • SelectManyThen

extension(IObservable source)

  • CatchIgnore

extension(IObservable this)

  • GetMax
  • GetMin

extension(IObservable source)

  • SkipWhileNull

extension(IObservable source)

  • Shuffle

extension(IObservable source)

  • Not
  • WhereTrue
  • WhereFalse

extension(IObservable this)

  • BufferUntil

extension(IObservable source)

  • Filter
  • Filter

extension(IObserver observer)

  • OnNext

extension(IReadOnlyList> sources)

  • RunAll

extension(IReadOnlyList candidates)

  • FirstMatchFromCandidates

extension(IScheduler? scheduler)

  • ScheduleSafe
  • ScheduleSafe

extension(T obj)

  • Using
  • Using
  • Using
  • Using

extension(T source)

  • ToPropertyObservable

extension(T value)

  • Schedule
  • Schedule
  • Schedule
  • Schedule
  • Schedule
  • Schedule