Skip to content

SignalAsyncExtensions class

Defined in

Namespace: ReactiveUI.Primitives.Async Assembly: ReactiveUI.Primitives.Async.Core.dll Full name: ReactiveUI.Primitives.Async.SignalAsyncExtensions Modifiers: public static

Summary

View source

Provides extension methods for working with asynchronous observers.

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, net471

Remarks

The methods in this class allow developers to filter out consecutive duplicates in observable sequences, either by value or by a specified key. These operations are useful for scenarios where only changes or distinct consecutive values are of interest, such as event streams or state change notifications.

Methods

NameSummary
static ToAsyncSignal
static AnyAsync
static AllAsync
static Blend
static Merge
static Cast
static CastTo
static Chain
static Concat
static ContainsAsync
static CountAsync
static Distinct
static DistinctBy
static Expire
static FirstAsync
static FirstOrDefaultAsync
static FlatMap
static Fold
static ForEachAsync
static GroupBy
static Keep
static KeepWith
static Where
static OfType
static KeepType
static LastAsync
static LastOrDefaultAsync
static Lead
static Prepend
static LongCountAsync
static Map
static MapWith
static Select
static Multicast
static Publish
static StatelessPublish
static ReplayLatestPublish
static StatelessReplayLatestPublish
static OnDispose
static OnErrorResumeAsFailure
static Pair
static CombineLatestValuesAreAllFalse
static CombineLatestValuesAreAllTrue
static ForEach
static CatchIgnore
static CatchAndReturn
static DoOnSubscribe
static DropIfBusy
static LatestOrDefault
static LogErrors
static WaitUntil
static Pairwise
static Partition
static ReplayLastOnSubscribe
static ThrottleDistinct
static ScanWithInitial
static DebounceUntil
static GetMin
static GetMax
static SkipWhileNull
static WhereIsNotNull
static Not
static WhereFalse
static WhereTrue
static Reattempt
static Recover
static Resume
static CatchAndIgnoreErrorResume
static AggregateAsync
static ReduceAsync
static RefCount
static Shift
static Bind
static Catch
static CombineLatest
static Delay
static DistinctUntilChanged
static DistinctUntilChangedBy
static KeepNotNull
static Rescue
static Retry
static Scan
static SelectMany
static Timeout
static Zip
static SingleAsync
static SingleOrDefaultAsync
static Skip
static SkipWhile
static StartWith
static SubscribeAsync
static SwitchTo
static Switch
static SyncLatest
static PairLatest
static Take
static TakeUntil
static TakeWhile
static Tap
static Do
static Throttle
static ToAsyncEnumerable
static ToDictionaryAsync
static CollectListAsync
static ToListAsync
static CollectArrayAsync
static Unique
static UniqueBy
static WaitCompletionAsync
static Wrap
Inherited members

Extension blocks

extension(IAsyncEnumerable this)

  • ToAsyncSignal

extension(IEnumerable this)

  • ToAsyncSignal

extension(IObservableAsync this)

  • ToAsyncSignal
  • AnyAsync
  • AnyAsync
  • AnyAsync
  • AllAsync
  • AllAsync
  • Blend
  • Merge
  • Cast
  • Chain
  • Concat
  • ContainsAsync
  • ContainsAsync
  • ContainsAsync
  • ContainsAsync
  • CountAsync
  • CountAsync
  • CountAsync
  • CountAsync
  • Distinct
  • Distinct
  • DistinctBy
  • DistinctBy
  • Expire
  • FirstAsync
  • FirstAsync
  • FirstAsync
  • FirstAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FlatMap
  • FlatMap
  • Fold
  • Fold
  • ForEachAsync
  • ForEachAsync
  • ForEachAsync
  • ForEachAsync
  • Keep
  • Keep
  • KeepWith
  • Where
  • Where
  • OfType
  • LastAsync
  • LastAsync
  • LastAsync
  • LastAsync
  • LastOrDefaultAsync
  • LastOrDefaultAsync
  • LastOrDefaultAsync
  • LastOrDefaultAsync
  • LastOrDefaultAsync
  • LastOrDefaultAsync
  • Lead
  • Prepend
  • Prepend
  • LongCountAsync
  • LongCountAsync
  • LongCountAsync
  • LongCountAsync
  • Map
  • Map
  • MapWith
  • Select
  • Select
  • OnDispose
  • OnDispose
  • OnErrorResumeAsFailure
  • Reattempt
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • Shift
  • Bind
  • Delay
  • Delay
  • DistinctUntilChanged
  • DistinctUntilChanged
  • DistinctUntilChangedBy
  • DistinctUntilChangedBy
  • Retry
  • Retry
  • Scan
  • Scan
  • SelectMany
  • SelectMany
  • SelectMany
  • Timeout
  • Timeout
  • Timeout
  • Timeout
  • SingleAsync
  • SingleAsync
  • SingleAsync
  • SingleAsync
  • SingleOrDefaultAsync
  • SingleOrDefaultAsync
  • SingleOrDefaultAsync
  • SingleOrDefaultAsync
  • SingleOrDefaultAsync
  • SingleOrDefaultAsync
  • Skip
  • SkipWhile
  • SkipWhile
  • StartWith
  • StartWith
  • StartWith
  • Take
  • TakeWhile
  • TakeWhile
  • Tap
  • Tap
  • Tap
  • Do
  • Do
  • Do
  • Do
  • Throttle
  • Throttle
  • ToAsyncEnumerable
  • ToAsyncEnumerable
  • ToDictionaryAsync
  • ToDictionaryAsync
  • ToDictionaryAsync
  • ToDictionaryAsync
  • CollectListAsync
  • ToListAsync
  • ToListAsync
  • CollectArrayAsync
  • Unique
  • Unique
  • UniqueBy
  • UniqueBy
  • WaitCompletionAsync
  • WaitCompletionAsync

extension(IObservableAsync source)

  • GroupBy
  • GroupBy

extension(IObservableAsync source)

  • Multicast
  • Publish
  • Publish
  • Publish
  • Publish
  • StatelessPublish
  • StatelessPublish
  • ReplayLatestPublish
  • ReplayLatestPublish
  • StatelessReplayLatestPublish
  • CatchIgnore
  • CatchIgnore
  • CatchAndReturn
  • CatchAndReturn
  • DoOnSubscribe
  • DoOnSubscribe
  • DropIfBusy
  • LatestOrDefault
  • LogErrors
  • WaitUntil
  • Pairwise
  • Partition
  • ReplayLastOnSubscribe
  • ThrottleDistinct
  • ThrottleDistinct
  • ScanWithInitial
  • ScanWithInitial
  • DebounceUntil
  • DebounceUntil
  • Recover
  • Resume
  • CatchAndIgnoreErrorResume
  • Catch
  • Catch
  • Rescue
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • SubscribeAsync
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil
  • TakeUntil

extension(IObservableAsync first)

  • Pair
  • Zip
  • Zip

extension(IObservableAsync src1)

  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • PairLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest
  • SyncLatest
  • CombineLatest

extension(Task this)

  • ToAsyncSignal

extension(IEnumerable> this)

  • Blend
  • Merge
  • Chain
  • Concat

extension(IEnumerable> sources)

  • CombineLatest
  • CombineLatest
  • SyncLatest
  • SyncLatest

extension(IObservableAsync> this)

  • Blend
  • Merge
  • Merge
  • Chain
  • Concat
  • SwitchTo
  • Switch

extension(IObservableAsync source)

  • CastTo
  • KeepType

extension(IEnumerable> sources)

  • CombineLatestValuesAreAllFalse
  • CombineLatestValuesAreAllTrue

extension(IObservableAsync> source)

  • ForEach

extension(IObservableAsync source)

  • GetMin
  • GetMax

extension(IObservableAsync source)

  • SkipWhileNull
  • WhereIsNotNull
  • KeepNotNull

extension(IObservableAsync source)

  • Not
  • WhereFalse
  • WhereTrue

extension(ConnectableSignalAsync source)

  • RefCount

extension(IObserverAsync observer)

  • Wrap