Skip to content

SignalAsyncExtensions class

Defined in

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

Summary

View source

Provides extension methods for working with asynchronous observable sequences.

Applies to

net10.0, net10.0, net10.0-desktop1.0, net10.0-desktop1.0, net10.0-browserwasm1.0, net10.0-browserwasm1.0, net9.0, net9.0, net9.0-desktop1.0, net9.0-desktop1.0, net9.0-browserwasm1.0, net9.0-browserwasm1.0, net8.0, net8.0, net8.0-ios17.5, net8.0-macos14.5, net8.0-macos14.5, net8.0-macos14.2, net8.0-macos14.2, net8.0-maccatalyst17.5, net8.0-maccatalyst17.5, net8.0-tvos17.2, net8.0-tvos17.2, net8.0-ios17.5, netstandard2.1, netstandard2.1, net481, net462, net462, net481

Remarks

The SignalAsync class contains static methods that extend the functionality of asynchronous observables, enabling advanced composition and control over asynchronous data streams. These methods are intended for use with types that implement asynchronous observer patterns.

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 Timeout
static FirstAsync
static FirstOrDefaultAsync
static FlatMap
static Bind
static SelectMany
static Fold
static Scan
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 Zip
static AsSignal
static CatchIgnore
static CatchAndReturn
static DoOnSubscribe
static DropIfBusy
static LatestOrDefault
static LogErrors
static WaitUntil
static ObserveOnSafe
static ObserveOnIf
static Pairwise
static Partition
static ReplayLastOnSubscribe
static ThrottleDistinct
static ScanWithInitial
static DebounceUntil
static GetMin
static GetMax
static CombineLatestValuesAreAllFalse
static CombineLatestValuesAreAllTrue
static ForEach
static Not
static WhereFalse
static WhereTrue
static SkipWhileNull
static WhereIsNotNull
static KeepNotNull
static Retry
static Reattempt
static Recover
static Catch
static Rescue
static Resume
static CatchAndIgnoreErrorResume
static AggregateAsync
static ReduceAsync
static RefCount
static Shift
static Delay
static SingleAsync
static SingleOrDefaultAsync
static Skip
static SkipWhile
static StartWith
static SubscribeAsync
static SwitchTo
static Switch
static SyncLatest
static CombineLatest
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 DistinctUntilChanged
static DistinctUntilChangedBy
static WaitCompletionAsync
static WitnessOn
static Wrap
static Yield
Inherited members

Extension blocks

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
  • Timeout
  • Timeout
  • Timeout
  • Timeout
  • FirstAsync
  • FirstAsync
  • FirstAsync
  • FirstAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FirstOrDefaultAsync
  • FlatMap
  • FlatMap
  • Bind
  • SelectMany
  • SelectMany
  • SelectMany
  • Fold
  • Fold
  • Scan
  • Scan
  • 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
  • Retry
  • Retry
  • Reattempt
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • AggregateAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • ReduceAsync
  • Shift
  • Delay
  • Delay
  • 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
  • DistinctUntilChanged
  • DistinctUntilChanged
  • DistinctUntilChangedBy
  • DistinctUntilChangedBy
  • WaitCompletionAsync
  • WaitCompletionAsync
  • WitnessOn
  • WitnessOn
  • WitnessOn
  • WitnessOn
  • WitnessOn
  • WitnessOn
  • WitnessOn
  • WitnessOn
  • Yield

extension(IObservableAsync source)

  • GroupBy
  • GroupBy

extension(IObservableAsync source)

  • Multicast
  • Publish
  • Publish
  • Publish
  • Publish
  • StatelessPublish
  • StatelessPublish
  • ReplayLatestPublish
  • ReplayLatestPublish
  • StatelessReplayLatestPublish
  • AsSignal
  • CatchIgnore
  • CatchIgnore
  • CatchAndReturn
  • CatchAndReturn
  • DoOnSubscribe
  • DoOnSubscribe
  • DropIfBusy
  • LatestOrDefault
  • LogErrors
  • WaitUntil
  • ObserveOnSafe
  • ObserveOnSafe
  • ObserveOnSafe
  • ObserveOnSafe
  • ObserveOnIf
  • ObserveOnIf
  • ObserveOnIf
  • ObserveOnIf
  • Pairwise
  • Partition
  • ReplayLastOnSubscribe
  • ThrottleDistinct
  • ThrottleDistinct
  • ScanWithInitial
  • ScanWithInitial
  • DebounceUntil
  • DebounceUntil
  • Recover
  • Catch
  • Catch
  • Rescue
  • Resume
  • CatchAndIgnoreErrorResume
  • 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(Task this)

  • ToAsyncSignal

extension(IAsyncEnumerable this)

  • ToAsyncSignal

extension(IEnumerable this)

  • ToAsyncSignal

extension(IObservableAsync> this)

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

extension(IEnumerable> this)

  • Blend
  • Merge
  • Chain
  • Concat

extension(IEnumerable> sources)

  • SyncLatest
  • SyncLatest
  • CombineLatest
  • CombineLatest

extension(IObservableAsync source)

  • CastTo
  • KeepType

extension(IObservableAsync source)

  • GetMin
  • GetMax

extension(IEnumerable> sources)

  • CombineLatestValuesAreAllFalse
  • CombineLatestValuesAreAllTrue

extension(IObservableAsync> source)

  • ForEach

extension(IObservableAsync source)

  • Not
  • WhereFalse
  • WhereTrue

extension(IObservableAsync source)

  • SkipWhileNull
  • WhereIsNotNull
  • KeepNotNull

extension(ConnectableSignalAsync source)

  • RefCount

extension(IObserverAsync observer)

  • Wrap