Static Public Member Functions
static IObservable< TSource >	Scan< TSource > (this IObservable< TSource > source, Func< TSource, TSource, TSource > accumulator)

static IObservable< TAccumulate >	Scan< TSource, TAccumulate > (this IObservable< TSource > source, TAccumulate seed, Func< TAccumulate, TSource, TAccumulate > accumulator)

static IObservable< TSource >	Aggregate< TSource > (this IObservable< TSource > source, Func< TSource, TSource, TSource > accumulator)

static IObservable< TAccumulate >	Aggregate< TSource, TAccumulate > (this IObservable< TSource > source, TAccumulate seed, Func< TAccumulate, TSource, TAccumulate > accumulator)

static IObservable< TResult >	Aggregate< TSource, TAccumulate, TResult > (this IObservable< TSource > source, TAccumulate seed, Func< TAccumulate, TSource, TAccumulate > accumulator, Func< TAccumulate, TResult > resultSelector)

static IConnectableObservable< T >	Multicast< T > (this IObservable< T > source, ISubject< T > subject)

static IConnectableObservable< T >	Publish< T > (this IObservable< T > source)

static IConnectableObservable< T >	Publish< T > (this IObservable< T > source, T initialValue)

static IConnectableObservable< T >	PublishLast< T > (this IObservable< T > source)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source, IScheduler scheduler)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source, int bufferSize)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source, int bufferSize, IScheduler scheduler)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source, TimeSpan window)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source, TimeSpan window, IScheduler scheduler)

static IConnectableObservable< T >	Replay< T > (this IObservable< T > source, int bufferSize, TimeSpan window, IScheduler scheduler)

static IObservable< T >	RefCount< T > (this IConnectableObservable< T > source)

static IObservable< T >	Share< T > (this IObservable< T > source)
	same as Publish().RefCount()

static T	Wait< T > (this IObservable< T > source)

static T	Wait< T > (this IObservable< T > source, TimeSpan timeout)

static IObservable< TSource >	Concat< TSource > (params IObservable< TSource >[] sources)

static IObservable< TSource >	Concat< TSource > (this IEnumerable< IObservable< TSource > > sources)

static IObservable< TSource >	Concat< TSource > (this IObservable< IObservable< TSource > > sources)

static IObservable< TSource >	Concat< TSource > (this IObservable< TSource > first, params IObservable< TSource >[] seconds)

static IObservable< TSource >	Merge< TSource > (this IEnumerable< IObservable< TSource > > sources)

static IObservable< TSource >	Merge< TSource > (this IEnumerable< IObservable< TSource > > sources, IScheduler scheduler)

static IObservable< TSource >	Merge< TSource > (this IEnumerable< IObservable< TSource > > sources, int maxConcurrent)

static IObservable< TSource >	Merge< TSource > (this IEnumerable< IObservable< TSource > > sources, int maxConcurrent, IScheduler scheduler)

static IObservable< TSource >	Merge< TSource > (params IObservable< TSource >[] sources)

static IObservable< TSource >	Merge< TSource > (IScheduler scheduler, params IObservable< TSource >[] sources)

static IObservable< T >	Merge< T > (this IObservable< T > first, params IObservable< T >[] seconds)

static IObservable< T >	Merge< T > (this IObservable< T > first, IObservable< T > second, IScheduler scheduler)

static IObservable< T >	Merge< T > (this IObservable< IObservable< T > > sources)

static IObservable< T >	Merge< T > (this IObservable< IObservable< T > > sources, int maxConcurrent)

static IObservable< TResult >	Zip< TLeft, TRight, TResult > (this IObservable< TLeft > left, IObservable< TRight > right, Func< TLeft, TRight, TResult > selector)

static IObservable< IList< T > >	Zip< T > (this IEnumerable< IObservable< T > > sources)

static IObservable< IList< T > >	Zip< T > (params IObservable< T >[] sources)

static IObservable< TR >	Zip< T1, T2, T3, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, ZipFunc< T1, T2, T3, TR > resultSelector)

static IObservable< TR >	Zip< T1, T2, T3, T4, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, ZipFunc< T1, T2, T3, T4, TR > resultSelector)

static IObservable< TR >	Zip< T1, T2, T3, T4, T5, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, ZipFunc< T1, T2, T3, T4, T5, TR > resultSelector)

static IObservable< TR >	Zip< T1, T2, T3, T4, T5, T6, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, IObservable< T6 > source6, ZipFunc< T1, T2, T3, T4, T5, T6, TR > resultSelector)

static IObservable< TR >	Zip< T1, T2, T3, T4, T5, T6, T7, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, IObservable< T6 > source6, IObservable< T7 > source7, ZipFunc< T1, T2, T3, T4, T5, T6, T7, TR > resultSelector)

static IObservable< TResult >	CombineLatest< TLeft, TRight, TResult > (this IObservable< TLeft > left, IObservable< TRight > right, Func< TLeft, TRight, TResult > selector)

static IObservable< IList< T > >	CombineLatest< T > (this IEnumerable< IObservable< T > > sources)

static IObservable< IList< TSource > >	CombineLatest< TSource > (params IObservable< TSource >[] sources)

static IObservable< TR >	CombineLatest< T1, T2, T3, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, CombineLatestFunc< T1, T2, T3, TR > resultSelector)

static IObservable< TR >	CombineLatest< T1, T2, T3, T4, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, CombineLatestFunc< T1, T2, T3, T4, TR > resultSelector)

static IObservable< TR >	CombineLatest< T1, T2, T3, T4, T5, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, CombineLatestFunc< T1, T2, T3, T4, T5, TR > resultSelector)

static IObservable< TR >	CombineLatest< T1, T2, T3, T4, T5, T6, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, IObservable< T6 > source6, CombineLatestFunc< T1, T2, T3, T4, T5, T6, TR > resultSelector)

static IObservable< TR >	CombineLatest< T1, T2, T3, T4, T5, T6, T7, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, IObservable< T6 > source6, IObservable< T7 > source7, CombineLatestFunc< T1, T2, T3, T4, T5, T6, T7, TR > resultSelector)

static IObservable< TResult >	ZipLatest< TLeft, TRight, TResult > (this IObservable< TLeft > left, IObservable< TRight > right, Func< TLeft, TRight, TResult > selector)

static IObservable< IList< T > >	ZipLatest< T > (this IEnumerable< IObservable< T > > sources)

static IObservable< IList< TSource > >	ZipLatest< TSource > (params IObservable< TSource >[] sources)

static IObservable< TR >	ZipLatest< T1, T2, T3, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, ZipLatestFunc< T1, T2, T3, TR > resultSelector)

static IObservable< TR >	ZipLatest< T1, T2, T3, T4, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, ZipLatestFunc< T1, T2, T3, T4, TR > resultSelector)

static IObservable< TR >	ZipLatest< T1, T2, T3, T4, T5, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, ZipLatestFunc< T1, T2, T3, T4, T5, TR > resultSelector)

static IObservable< TR >	ZipLatest< T1, T2, T3, T4, T5, T6, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, IObservable< T6 > source6, ZipLatestFunc< T1, T2, T3, T4, T5, T6, TR > resultSelector)

static IObservable< TR >	ZipLatest< T1, T2, T3, T4, T5, T6, T7, TR > (this IObservable< T1 > source1, IObservable< T2 > source2, IObservable< T3 > source3, IObservable< T4 > source4, IObservable< T5 > source5, IObservable< T6 > source6, IObservable< T7 > source7, ZipLatestFunc< T1, T2, T3, T4, T5, T6, T7, TR > resultSelector)

static IObservable< T >	Switch< T > (this IObservable< IObservable< T > > sources)

static IObservable< TResult >	WithLatestFrom< TLeft, TRight, TResult > (this IObservable< TLeft > left, IObservable< TRight > right, Func< TLeft, TRight, TResult > selector)

static IObservable< T[]>	WhenAll< T > (params IObservable< T >[] sources)

static IObservable< Unit >	WhenAll (params IObservable< Unit >[] sources)

static IObservable< T[]>	WhenAll< T > (this IEnumerable< IObservable< T > > sources)

static IObservable< Unit >	WhenAll (this IEnumerable< IObservable< Unit > > sources)

static IObservable< T >	StartWith< T > (this IObservable< T > source, T value)

static IObservable< T >	StartWith< T > (this IObservable< T > source, Func< T > valueFactory)

static IObservable< T >	StartWith< T > (this IObservable< T > source, params T[] values)

static IObservable< T >	StartWith< T > (this IObservable< T > source, IEnumerable< T > values)

static IObservable< T >	StartWith< T > (this IObservable< T > source, IScheduler scheduler, T value)

static IObservable< T >	StartWith< T > (this IObservable< T > source, IScheduler scheduler, IEnumerable< T > values)

static IObservable< T >	StartWith< T > (this IObservable< T > source, IScheduler scheduler, params T[] values)

static IObservable< T >	Synchronize< T > (this IObservable< T > source)

static IObservable< T >	Synchronize< T > (this IObservable< T > source, object gate)

static IObservable< T >	ObserveOn< T > (this IObservable< T > source, IScheduler scheduler)

static IObservable< T >	SubscribeOn< T > (this IObservable< T > source, IScheduler scheduler)

static IObservable< T >	DelaySubscription< T > (this IObservable< T > source, TimeSpan dueTime)

static IObservable< T >	DelaySubscription< T > (this IObservable< T > source, TimeSpan dueTime, IScheduler scheduler)

static IObservable< T >	DelaySubscription< T > (this IObservable< T > source, DateTimeOffset dueTime)

static IObservable< T >	DelaySubscription< T > (this IObservable< T > source, DateTimeOffset dueTime, IScheduler scheduler)

static IObservable< T >	Amb< T > (params IObservable< T >[] sources)

static IObservable< T >	Amb< T > (IEnumerable< IObservable< T > > sources)

static IObservable< T >	Amb< T > (this IObservable< T > source, IObservable< T > second)

static IObservable< T >	AsObservable< T > (this IObservable< T > source)

static IObservable< T >	ToObservable< T > (this IEnumerable< T > source)

static IObservable< T >	ToObservable< T > (this IEnumerable< T > source, IScheduler scheduler)

static IObservable< TResult >	Cast< TSource, TResult > (this IObservable< TSource > source)

static IObservable< TResult >	Cast< TSource, TResult > (this IObservable< TSource > source, TResult witness)
	witness is for type inference.

static IObservable< TResult >	OfType< TSource, TResult > (this IObservable< TSource > source)

static IObservable< TResult >	OfType< TSource, TResult > (this IObservable< TSource > source, TResult witness)
	witness is for type inference.

static IObservable< Unit >	AsUnitObservable< T > (this IObservable< T > source)
	Converting .Select(_ => Unit.Default) sequence.

static IObservable< Unit >	AsSingleUnitObservable< T > (this IObservable< T > source)
	Same as LastOrDefault().AsUnitObservable().

static IObservable< T >	Create< T > (Func< IObserver< T >, IDisposable > subscribe)
	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator.

static IObservable< T >	Create< T > (Func< IObserver< T >, IDisposable > subscribe, bool isRequiredSubscribeOnCurrentThread)
	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator(HotObservable).

static IObservable< T >	CreateWithState< T, TState > (TState state, Func< TState, IObserver< T >, IDisposable > subscribe)
	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator.

static IObservable< T >	CreateWithState< T, TState > (TState state, Func< TState, IObserver< T >, IDisposable > subscribe, bool isRequiredSubscribeOnCurrentThread)
	Create anonymous observable. Observer has exception durability. This is recommended for make operator and event like generator(HotObservable).

static IObservable< T >	CreateSafe< T > (Func< IObserver< T >, IDisposable > subscribe)
	Create anonymous observable. Safe means auto detach when error raised in onNext pipeline. This is recommended for make generator (ColdObservable).

static IObservable< T >	CreateSafe< T > (Func< IObserver< T >, IDisposable > subscribe, bool isRequiredSubscribeOnCurrentThread)
	Create anonymous observable. Safe means auto detach when error raised in onNext pipeline. This is recommended for make generator (ColdObservable).

static IObservable< T >	Empty< T > ()
	Empty Observable. Returns only OnCompleted.

static IObservable< T >	Empty< T > (IScheduler scheduler)
	Empty Observable. Returns only OnCompleted on specified scheduler.

static IObservable< T >	Empty< T > (T witness)
	Empty Observable. Returns only OnCompleted. witness is for type inference.

static IObservable< T >	Empty< T > (IScheduler scheduler, T witness)
	Empty Observable. Returns only OnCompleted on specified scheduler. witness is for type inference.

static IObservable< T >	Never< T > ()
	Non-Terminating Observable. It's no returns, never finish.

static IObservable< T >	Never< T > (T witness)
	Non-Terminating Observable. It's no returns, never finish. witness is for type inference.

static IObservable< T >	Return< T > (T value)
	Return single sequence Immediately.

static IObservable< T >	Return< T > (T value, IScheduler scheduler)
	Return single sequence on specified scheduler.

static IObservable< Unit >	Return (Unit value)
	Return single sequence Immediately, optimized for Unit(no allocate memory).

static IObservable< bool >	Return (bool value)
	Return single sequence Immediately, optimized for Boolean(no allocate memory).

static IObservable< Int32 >	Return (int value)
	Return single sequence Immediately, optimized for Int32.

static IObservable< Unit >	ReturnUnit ()
	Same as Observable.Return(Unit.Default); but no allocate memory.

static IObservable< T >	Throw< T > (Exception error)
	Empty Observable. Returns only onError.

static IObservable< T >	Throw< T > (Exception error, T witness)
	Empty Observable. Returns only onError. witness if for Type inference.

static IObservable< T >	Throw< T > (Exception error, IScheduler scheduler)
	Empty Observable. Returns only onError on specified scheduler.

static IObservable< T >	Throw< T > (Exception error, IScheduler scheduler, T witness)
	Empty Observable. Returns only onError on specified scheduler. witness if for Type inference.

static IObservable< int >	Range (int start, int count)

static IObservable< int >	Range (int start, int count, IScheduler scheduler)

static IObservable< T >	Repeat< T > (T value)

static IObservable< T >	Repeat< T > (T value, IScheduler scheduler)

static IObservable< T >	Repeat< T > (T value, int repeatCount)

static IObservable< T >	Repeat< T > (T value, int repeatCount, IScheduler scheduler)

static IObservable< T >	Repeat< T > (this IObservable< T > source)

static IObservable< T >	RepeatSafe< T > (this IObservable< T > source)
	Same as Repeat() but if arriving contiguous "OnComplete" Repeat stops.

static IObservable< T >	Defer< T > (Func< IObservable< T > > observableFactory)

static IObservable< T >	Start< T > (Func< T > function)

static IObservable< T >	Start< T > (Func< T > function, TimeSpan timeSpan)

static IObservable< T >	Start< T > (Func< T > function, IScheduler scheduler)

static IObservable< T >	Start< T > (Func< T > function, TimeSpan timeSpan, IScheduler scheduler)

static IObservable< Unit >	Start (Action action)

static IObservable< Unit >	Start (Action action, TimeSpan timeSpan)

static IObservable< Unit >	Start (Action action, IScheduler scheduler)

static IObservable< Unit >	Start (Action action, TimeSpan timeSpan, IScheduler scheduler)

static Func< IObservable< T > >	ToAsync< T > (Func< T > function)

static Func< IObservable< T > >	ToAsync< T > (Func< T > function, IScheduler scheduler)

static Func< IObservable< Unit > >	ToAsync (Action action)

static Func< IObservable< Unit > >	ToAsync (Action action, IScheduler scheduler)

static IObservable< TR >	Select< T, TR > (this IObservable< T > source, Func< T, TR > selector)

static IObservable< TR >	Select< T, TR > (this IObservable< T > source, Func< T, int, TR > selector)

static IObservable< T >	Where< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	Where< T > (this IObservable< T > source, Func< T, int, bool > predicate)

static IObservable< TR >	ContinueWith< T, TR > (this IObservable< T > source, IObservable< TR > other)
	Lightweight SelectMany for Single Async Operation.

static IObservable< TR >	ContinueWith< T, TR > (this IObservable< T > source, Func< T, IObservable< TR > > selector)
	Lightweight SelectMany for Single Async Operation.

static IObservable< TR >	SelectMany< T, TR > (this IObservable< T > source, IObservable< TR > other)

static IObservable< TR >	SelectMany< T, TR > (this IObservable< T > source, Func< T, IObservable< TR > > selector)

static IObservable< TResult >	SelectMany< TSource, TResult > (this IObservable< TSource > source, Func< TSource, int, IObservable< TResult > > selector)

static IObservable< TR >	SelectMany< T, TC, TR > (this IObservable< T > source, Func< T, IObservable< TC > > collectionSelector, Func< T, TC, TR > resultSelector)

static IObservable< TResult >	SelectMany< TSource, TCollection, TResult > (this IObservable< TSource > source, Func< TSource, int, IObservable< TCollection > > collectionSelector, Func< TSource, int, TCollection, int, TResult > resultSelector)

static IObservable< TResult >	SelectMany< TSource, TResult > (this IObservable< TSource > source, Func< TSource, IEnumerable< TResult > > selector)

static IObservable< TResult >	SelectMany< TSource, TResult > (this IObservable< TSource > source, Func< TSource, int, IEnumerable< TResult > > selector)

static IObservable< TResult >	SelectMany< TSource, TCollection, TResult > (this IObservable< TSource > source, Func< TSource, IEnumerable< TCollection > > collectionSelector, Func< TSource, TCollection, TResult > resultSelector)

static IObservable< TResult >	SelectMany< TSource, TCollection, TResult > (this IObservable< TSource > source, Func< TSource, int, IEnumerable< TCollection > > collectionSelector, Func< TSource, int, TCollection, int, TResult > resultSelector)

static IObservable< T[]>	ToArray< T > (this IObservable< T > source)

static IObservable< IList< T > >	ToList< T > (this IObservable< T > source)

static IObservable< T >	Do< T > (this IObservable< T > source, IObserver< T > observer)

static IObservable< T >	Do< T > (this IObservable< T > source, Action< T > onNext)

static IObservable< T >	Do< T > (this IObservable< T > source, Action< T > onNext, Action< Exception > onError)

static IObservable< T >	Do< T > (this IObservable< T > source, Action< T > onNext, Action onCompleted)

static IObservable< T >	Do< T > (this IObservable< T > source, Action< T > onNext, Action< Exception > onError, Action onCompleted)

static IObservable< T >	DoOnError< T > (this IObservable< T > source, Action< Exception > onError)

static IObservable< T >	DoOnCompleted< T > (this IObservable< T > source, Action onCompleted)

static IObservable< T >	DoOnTerminate< T > (this IObservable< T > source, Action onTerminate)

static IObservable< T >	DoOnSubscribe< T > (this IObservable< T > source, Action onSubscribe)

static IObservable< T >	DoOnCancel< T > (this IObservable< T > source, Action onCancel)

static IObservable< Notification< T > >	Materialize< T > (this IObservable< T > source)

static IObservable< T >	Dematerialize< T > (this IObservable< Notification< T > > source)

static IObservable< T >	DefaultIfEmpty< T > (this IObservable< T > source)

static IObservable< T >	DefaultIfEmpty< T > (this IObservable< T > source, T defaultValue)

static IObservable< TSource >	Distinct< TSource > (this IObservable< TSource > source)

static IObservable< TSource >	Distinct< TSource > (this IObservable< TSource > source, IEqualityComparer< TSource > comparer)

static IObservable< TSource >	Distinct< TSource, TKey > (this IObservable< TSource > source, Func< TSource, TKey > keySelector)

static IObservable< TSource >	Distinct< TSource, TKey > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, IEqualityComparer< TKey > comparer)

static IObservable< T >	DistinctUntilChanged< T > (this IObservable< T > source)

static IObservable< T >	DistinctUntilChanged< T > (this IObservable< T > source, IEqualityComparer< T > comparer)

static IObservable< T >	DistinctUntilChanged< T, TKey > (this IObservable< T > source, Func< T, TKey > keySelector)

static IObservable< T >	DistinctUntilChanged< T, TKey > (this IObservable< T > source, Func< T, TKey > keySelector, IEqualityComparer< TKey > comparer)

static IObservable< T >	IgnoreElements< T > (this IObservable< T > source)

static IObservable< Unit >	ForEachAsync< T > (this IObservable< T > source, Action< T > onNext)

static IObservable< Unit >	ForEachAsync< T > (this IObservable< T > source, Action< T, int > onNext)

static IObservable< T >	Finally< T > (this IObservable< T > source, Action finallyAction)

static IObservable< T >	Catch< T, TException > (this IObservable< T > source, Func< TException, IObservable< T > > errorHandler)

static IObservable< TSource >	Catch< TSource > (this IEnumerable< IObservable< TSource > > sources)

static IObservable< TSource >	CatchIgnore< TSource > (this IObservable< TSource > source)
	Catch exception and return Observable.Empty.

static IObservable< TSource >	CatchIgnore< TSource, TException > (this IObservable< TSource > source, Action< TException > errorAction)
	Catch exception and return Observable.Empty. More...

static IObservable< TSource >	Retry< TSource > (this IObservable< TSource > source)

static IObservable< TSource >	Retry< TSource > (this IObservable< TSource > source, int retryCount)

static IObservable< TSource >	OnErrorRetry< TSource > (this IObservable< TSource > source)

static IObservable< TSource >	OnErrorRetry< TSource, TException > (this IObservable< TSource > source, Action< TException > onError)
	When catched exception, do onError action and repeat observable sequence. More...

static IObservable< TSource >	OnErrorRetry< TSource, TException > (this IObservable< TSource > source, Action< TException > onError, TimeSpan delay)
	When catched exception, do onError action and repeat observable sequence after delay time. More...

static IObservable< TSource >	OnErrorRetry< TSource, TException > (this IObservable< TSource > source, Action< TException > onError, int retryCount)
	When catched exception, do onError action and repeat observable sequence during within retryCount. More...

static IObservable< TSource >	OnErrorRetry< TSource, TException > (this IObservable< TSource > source, Action< TException > onError, int retryCount, TimeSpan delay)
	When catched exception, do onError action and repeat observable sequence after delay time during within retryCount. More...

static IObservable< TSource >	OnErrorRetry< TSource, TException > (this IObservable< TSource > source, Action< TException > onError, int retryCount, TimeSpan delay, IScheduler delayScheduler)
	When catched exception, do onError action and repeat observable sequence after delay time(work on delayScheduler) during within retryCount. More...

static IObservable< EventPattern< TEventArgs > >	FromEventPattern< TDelegate, TEventArgs > (Func< EventHandler< TEventArgs >, TDelegate > conversion, Action< TDelegate > addHandler, Action< TDelegate > removeHandler)

static IObservable< Unit >	FromEvent< TDelegate > (Func< Action, TDelegate > conversion, Action< TDelegate > addHandler, Action< TDelegate > removeHandler)

static IObservable< TEventArgs >	FromEvent< TDelegate, TEventArgs > (Func< Action< TEventArgs >, TDelegate > conversion, Action< TDelegate > addHandler, Action< TDelegate > removeHandler)

static IObservable< Unit >	FromEvent (Action< Action > addHandler, Action< Action > removeHandler)

static IObservable< T >	FromEvent< T > (Action< Action< T > > addHandler, Action< Action< T > > removeHandler)

static Func< IObservable< TResult > >	FromAsyncPattern< TResult > (Func< AsyncCallback, object, IAsyncResult > begin, Func< IAsyncResult, TResult > end)

static Func< T1, IObservable< TResult > >	FromAsyncPattern< T1, TResult > (Func< T1, AsyncCallback, object, IAsyncResult > begin, Func< IAsyncResult, TResult > end)

static Func< T1, T2, IObservable< TResult > >	FromAsyncPattern< T1, T2, TResult > (Func< T1, T2, AsyncCallback, object, IAsyncResult > begin, Func< IAsyncResult, TResult > end)

static Func< IObservable< Unit > >	FromAsyncPattern (Func< AsyncCallback, object, IAsyncResult > begin, Action< IAsyncResult > end)

static Func< T1, IObservable< Unit > >	FromAsyncPattern< T1 > (Func< T1, AsyncCallback, object, IAsyncResult > begin, Action< IAsyncResult > end)

static Func< T1, T2, IObservable< Unit > >	FromAsyncPattern< T1, T2 > (Func< T1, T2, AsyncCallback, object, IAsyncResult > begin, Action< IAsyncResult > end)

static IObservable< T >	Take< T > (this IObservable< T > source, int count)

static IObservable< T >	Take< T > (this IObservable< T > source, TimeSpan duration)

static IObservable< T >	Take< T > (this IObservable< T > source, TimeSpan duration, IScheduler scheduler)

static IObservable< T >	TakeWhile< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	TakeWhile< T > (this IObservable< T > source, Func< T, int, bool > predicate)

static IObservable< T >	TakeUntil< T, TOther > (this IObservable< T > source, IObservable< TOther > other)

static IObservable< T >	TakeLast< T > (this IObservable< T > source, int count)

static IObservable< T >	TakeLast< T > (this IObservable< T > source, TimeSpan duration)

static IObservable< T >	TakeLast< T > (this IObservable< T > source, TimeSpan duration, IScheduler scheduler)

static IObservable< T >	Skip< T > (this IObservable< T > source, int count)

static IObservable< T >	Skip< T > (this IObservable< T > source, TimeSpan duration)

static IObservable< T >	Skip< T > (this IObservable< T > source, TimeSpan duration, IScheduler scheduler)

static IObservable< T >	SkipWhile< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	SkipWhile< T > (this IObservable< T > source, Func< T, int, bool > predicate)

static IObservable< T >	SkipUntil< T, TOther > (this IObservable< T > source, IObservable< TOther > other)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, int count)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, int count, int skip)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, TimeSpan timeSpan)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, TimeSpan timeSpan, IScheduler scheduler)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, TimeSpan timeSpan, int count)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, TimeSpan timeSpan, int count, IScheduler scheduler)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, TimeSpan timeSpan, TimeSpan timeShift)

static IObservable< IList< T > >	Buffer< T > (this IObservable< T > source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler)

static IObservable< IList< TSource > >	Buffer< TSource, TWindowBoundary > (this IObservable< TSource > source, IObservable< TWindowBoundary > windowBoundaries)

static IObservable< Pair< T > >	Pairwise< T > (this IObservable< T > source)
	Projects old and new element of a sequence into a new form.

static IObservable< TR >	Pairwise< T, TR > (this IObservable< T > source, Func< T, T, TR > selector)
	Projects old and new element of a sequence into a new form.

static IObservable< T >	Last< T > (this IObservable< T > source)

static IObservable< T >	Last< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	LastOrDefault< T > (this IObservable< T > source)

static IObservable< T >	LastOrDefault< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	First< T > (this IObservable< T > source)

static IObservable< T >	First< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	FirstOrDefault< T > (this IObservable< T > source)

static IObservable< T >	FirstOrDefault< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	Single< T > (this IObservable< T > source)

static IObservable< T >	Single< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< T >	SingleOrDefault< T > (this IObservable< T > source)

static IObservable< T >	SingleOrDefault< T > (this IObservable< T > source, Func< T, bool > predicate)

static IObservable< IGroupedObservable< TKey, TSource > >	GroupBy< TSource, TKey > (this IObservable< TSource > source, Func< TSource, TKey > keySelector)

static IObservable< IGroupedObservable< TKey, TSource > >	GroupBy< TSource, TKey > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, IEqualityComparer< TKey > comparer)

static IObservable< IGroupedObservable< TKey, TElement > >	GroupBy< TSource, TKey, TElement > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, Func< TSource, TElement > elementSelector)

static IObservable< IGroupedObservable< TKey, TElement > >	GroupBy< TSource, TKey, TElement > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, Func< TSource, TElement > elementSelector, IEqualityComparer< TKey > comparer)

static IObservable< IGroupedObservable< TKey, TSource > >	GroupBy< TSource, TKey > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, int capacity)

static IObservable< IGroupedObservable< TKey, TSource > >	GroupBy< TSource, TKey > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, int capacity, IEqualityComparer< TKey > comparer)

static IObservable< IGroupedObservable< TKey, TElement > >	GroupBy< TSource, TKey, TElement > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, Func< TSource, TElement > elementSelector, int capacity)

static IObservable< IGroupedObservable< TKey, TElement > >	GroupBy< TSource, TKey, TElement > (this IObservable< TSource > source, Func< TSource, TKey > keySelector, Func< TSource, TElement > elementSelector, int capacity, IEqualityComparer< TKey > comparer)

static IObservable< long >	Interval (TimeSpan period)

static IObservable< long >	Interval (TimeSpan period, IScheduler scheduler)

static IObservable< long >	Timer (TimeSpan dueTime)

static IObservable< long >	Timer (DateTimeOffset dueTime)

static IObservable< long >	Timer (TimeSpan dueTime, TimeSpan period)

static IObservable< long >	Timer (DateTimeOffset dueTime, TimeSpan period)

static IObservable< long >	Timer (TimeSpan dueTime, IScheduler scheduler)

static IObservable< long >	Timer (DateTimeOffset dueTime, IScheduler scheduler)

static IObservable< long >	Timer (TimeSpan dueTime, TimeSpan period, IScheduler scheduler)

static IObservable< long >	Timer (DateTimeOffset dueTime, TimeSpan period, IScheduler scheduler)

static IObservable< Timestamped< TSource > >	Timestamp< TSource > (this IObservable< TSource > source)

static IObservable< Timestamped< TSource > >	Timestamp< TSource > (this IObservable< TSource > source, IScheduler scheduler)

static IObservable< UniRx.TimeInterval< TSource > >	TimeInterval< TSource > (this IObservable< TSource > source)

static IObservable< UniRx.TimeInterval< TSource > >	TimeInterval< TSource > (this IObservable< TSource > source, IScheduler scheduler)

static IObservable< T >	Delay< T > (this IObservable< T > source, TimeSpan dueTime)

static IObservable< TSource >	Delay< TSource > (this IObservable< TSource > source, TimeSpan dueTime, IScheduler scheduler)

static IObservable< T >	Sample< T > (this IObservable< T > source, TimeSpan interval)

static IObservable< T >	Sample< T > (this IObservable< T > source, TimeSpan interval, IScheduler scheduler)

static IObservable< TSource >	Throttle< TSource > (this IObservable< TSource > source, TimeSpan dueTime)

static IObservable< TSource >	Throttle< TSource > (this IObservable< TSource > source, TimeSpan dueTime, IScheduler scheduler)

static IObservable< TSource >	ThrottleFirst< TSource > (this IObservable< TSource > source, TimeSpan dueTime)

static IObservable< TSource >	ThrottleFirst< TSource > (this IObservable< TSource > source, TimeSpan dueTime, IScheduler scheduler)

static IObservable< T >	Timeout< T > (this IObservable< T > source, TimeSpan dueTime)

static IObservable< T >	Timeout< T > (this IObservable< T > source, TimeSpan dueTime, IScheduler scheduler)

static IObservable< T >	Timeout< T > (this IObservable< T > source, DateTimeOffset dueTime)

static IObservable< T >	Timeout< T > (this IObservable< T > source, DateTimeOffset dueTime, IScheduler scheduler)

static IObservable< Unit >	FromCoroutine (Func< IEnumerator > coroutine, bool publishEveryYield=false)
	From has no callback coroutine to IObservable. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.

static IObservable< Unit >	FromCoroutine (Func< CancellationToken, IEnumerator > coroutine, bool publishEveryYield=false)
	From has no callback coroutine to IObservable. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.

static IObservable< Unit >	FromMicroCoroutine (Func< IEnumerator > coroutine, bool publishEveryYield=false, FrameCountType frameCountType=FrameCountType.Update)
	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.

static IObservable< Unit >	FromMicroCoroutine (Func< CancellationToken, IEnumerator > coroutine, bool publishEveryYield=false, FrameCountType frameCountType=FrameCountType.Update)
	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null. If publishEveryYield = true then publish OnNext every yield return else return once on enumeration completed.

static IObservable< T >	FromCoroutineValue< T > (Func< IEnumerator > coroutine, bool nullAsNextUpdate=true)
	Convert coroutine to typed IObservable. If nullAsNextUpdate = true then yield return null when Enumerator.Current and no null publish observer.OnNext.

static IObservable< T >	FromCoroutineValue< T > (Func< CancellationToken, IEnumerator > coroutine, bool nullAsNextUpdate=true)
	Convert coroutine to typed IObservable. If nullAsNextUpdate = true then yield return null when Enumerator.Current and no null publish observer.OnNext.

static IObservable< T >	FromCoroutine< T > (Func< IObserver< T >, IEnumerator > coroutine)

static IObservable< T >	FromMicroCoroutine< T > (Func< IObserver< T >, IEnumerator > coroutine, FrameCountType frameCountType=FrameCountType.Update)
	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null.

static IObservable< T >	FromCoroutine< T > (Func< IObserver< T >, CancellationToken, IEnumerator > coroutine)

static IObservable< T >	FromMicroCoroutine< T > (Func< IObserver< T >, CancellationToken, IEnumerator > coroutine, FrameCountType frameCountType=FrameCountType.Update)
	MicroCoroutine is lightweight, fast coroutine dispatcher. IEnumerator supports only yield return null.

static IObservable< Unit >	SelectMany< T > (this IObservable< T > source, IEnumerator coroutine, bool publishEveryYield=false)

static IObservable< Unit >	SelectMany< T > (this IObservable< T > source, Func< IEnumerator > selector, bool publishEveryYield=false)

static IObservable< Unit >	SelectMany< T > (this IObservable< T > source, Func< T, IEnumerator > selector)
	Note: publishEveryYield is always false. If you want to set true, use Observable.FromCoroutine(() => selector(x), true). This is workaround of Unity compiler's bug.

static IObservable< Unit >	ToObservable (this IEnumerator coroutine, bool publishEveryYield=false)

static ObservableYieldInstruction< Unit >	ToYieldInstruction (this IEnumerator coroutine)

static ObservableYieldInstruction< Unit >	ToYieldInstruction (this IEnumerator coroutine, bool throwOnError)

static ObservableYieldInstruction< Unit >	ToYieldInstruction (this IEnumerator coroutine, CancellationToken cancellationToken)

static ObservableYieldInstruction< Unit >	ToYieldInstruction (this IEnumerator coroutine, bool throwOnError, CancellationToken cancellationToken)

static IObservable< long >	EveryUpdate ()
	EveryUpdate calls coroutine's yield return null timing. It is after all Update and before LateUpdate.

static IObservable< long >	EveryFixedUpdate ()

static IObservable< long >	EveryEndOfFrame ()

static IObservable< long >	EveryGameObjectUpdate ()
	EveryGameObjectUpdate calls from MainThreadDispatcher's Update.

static IObservable< long >	EveryLateUpdate ()
	EveryLateUpdate calls from MainThreadDispatcher's OnLateUpdate.

static IObservable< long >	EveryAfterUpdate ()
	[Obsolete]Same as EveryUpdate.

static IObservable< Unit >	NextFrame (FrameCountType frameCountType=FrameCountType.Update)

static IObservable< long >	IntervalFrame (int intervalFrameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< long >	TimerFrame (int dueTimeFrameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< long >	TimerFrame (int dueTimeFrameCount, int periodFrameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< T >	DelayFrame< T > (this IObservable< T > source, int frameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< T >	Sample< T, T2 > (this IObservable< T > source, IObservable< T2 > sampler)

static IObservable< T >	SampleFrame< T > (this IObservable< T > source, int frameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< TSource >	ThrottleFrame< TSource > (this IObservable< TSource > source, int frameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< TSource >	ThrottleFirstFrame< TSource > (this IObservable< TSource > source, int frameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< T >	TimeoutFrame< T > (this IObservable< T > source, int frameCount, FrameCountType frameCountType=FrameCountType.Update)

static IObservable< T >	DelayFrameSubscription< T > (this IObservable< T > source, int frameCount, FrameCountType frameCountType=FrameCountType.Update)

static ObservableYieldInstruction< T >	ToYieldInstruction< T > (this IObservable< T > source)
	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).

static ObservableYieldInstruction< T >	ToYieldInstruction< T > (this IObservable< T > source, CancellationToken cancel)
	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. This overload throws exception if received OnError events(same as coroutine).

static ObservableYieldInstruction< T >	ToYieldInstruction< T > (this IObservable< T > source, bool throwOnError)
	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. If throwOnError = false, you can take ObservableYieldInstruction.HasError/Error property.

static ObservableYieldInstruction< T >	ToYieldInstruction< T > (this IObservable< T > source, bool throwOnError, CancellationToken cancel)
	Convert to yieldable IEnumerator. e.g. yield return source.ToYieldInstruction();. If needs last result, you can take ObservableYieldInstruction.HasResult/Result property. If throwOnError = false, you can take ObservableYieldInstruction.HasError/Error property.

static IEnumerator	ToAwaitableEnumerator< T > (this IObservable< T > source, CancellationToken cancel=default(CancellationToken))
	Convert to awaitable IEnumerator.

static IEnumerator	ToAwaitableEnumerator< T > (this IObservable< T > source, Action< T > onResult, CancellationToken cancel=default(CancellationToken))
	Convert to awaitable IEnumerator.

static IEnumerator	ToAwaitableEnumerator< T > (this IObservable< T > source, Action< Exception > onError, CancellationToken cancel=default(CancellationToken))
	Convert to awaitable IEnumerator.

static IEnumerator	ToAwaitableEnumerator< T > (this IObservable< T > source, Action< T > onResult, Action< Exception > onError, CancellationToken cancel=default(CancellationToken))
	Convert to awaitable IEnumerator.

static Coroutine	StartAsCoroutine< T > (this IObservable< T > source, CancellationToken cancel=default(CancellationToken))
	AutoStart observable as coroutine.

static Coroutine	StartAsCoroutine< T > (this IObservable< T > source, Action< T > onResult, CancellationToken cancel=default(CancellationToken))
	AutoStart observable as coroutine.

static Coroutine	StartAsCoroutine< T > (this IObservable< T > source, Action< Exception > onError, CancellationToken cancel=default(CancellationToken))
	AutoStart observable as coroutine.

static Coroutine	StartAsCoroutine< T > (this IObservable< T > source, Action< T > onResult, Action< Exception > onError, CancellationToken cancel=default(CancellationToken))
	AutoStart observable as coroutine.

static IObservable< T >	ObserveOnMainThread< T > (this IObservable< T > source)

static IObservable< T >	ObserveOnMainThread< T > (this IObservable< T > source, MainThreadDispatchType dispatchType)

static IObservable< T >	SubscribeOnMainThread< T > (this IObservable< T > source)

static IObservable< bool >	EveryApplicationPause ()

static IObservable< bool >	EveryApplicationFocus ()

static IObservable< Unit >	OnceApplicationQuit ()
	publish OnNext(Unit) and OnCompleted() on application quit.

static IObservable< T >	TakeUntilDestroy< T > (this IObservable< T > source, Component target)

static IObservable< T >	TakeUntilDestroy< T > (this IObservable< T > source, GameObject target)

static IObservable< T >	TakeUntilDisable< T > (this IObservable< T > source, Component target)

static IObservable< T >	TakeUntilDisable< T > (this IObservable< T > source, GameObject target)

static IObservable< T >	RepeatUntilDestroy< T > (this IObservable< T > source, GameObject target)

static IObservable< T >	RepeatUntilDestroy< T > (this IObservable< T > source, Component target)

static IObservable< T >	RepeatUntilDisable< T > (this IObservable< T > source, GameObject target)

static IObservable< T >	RepeatUntilDisable< T > (this IObservable< T > source, Component target)

static IObservable< UniRx.FrameInterval< T > >	FrameInterval< T > (this IObservable< T > source)

static IObservable< UniRx.TimeInterval< T > >	FrameTimeInterval< T > (this IObservable< T > source, bool ignoreTimeScale=false)

static IObservable< IList< T > >	BatchFrame< T > (this IObservable< T > source)
	Buffer elements in during target frame counts. Default raise same frame of end(frameCount = 0, frameCountType = EndOfFrame).

static IObservable< IList< T > >	BatchFrame< T > (this IObservable< T > source, int frameCount, FrameCountType frameCountType)
	Buffer elements in during target frame counts.

static IObservable< Unit >	BatchFrame (this IObservable< Unit > source)
	Wait command in during target frame counts. Default raise same frame of end(frameCount = 0, frameCountType = EndOfFrame).

static IObservable< Unit >	BatchFrame (this IObservable< Unit > source, int frameCount, FrameCountType frameCountType)
	Wait command in during target frame counts.

Member Function Documentation

◆ Catch< T, TException >()

static IObservable< T > UniRx.Observable.Catch< T, TException >	(	this IObservable< T >	source,
		Func< TException, IObservable< T > >	errorHandler
	)

static

Type Constraints

TException

:

Exception

◆ CatchIgnore< TSource, TException >()

static IObservable< TSource > UniRx.Observable.CatchIgnore< TSource, TException >	(	this IObservable< TSource >	source,
		Action< TException >	errorAction
	)

static

Catch exception and return Observable.Empty.

Type Constraints

TException

:

Exception

◆ FromEventPattern< TDelegate, TEventArgs >()

static IObservable< EventPattern< TEventArgs > > UniRx.Observable.FromEventPattern< TDelegate, TEventArgs >	(	Func< EventHandler< TEventArgs >, TDelegate >	conversion,
		Action< TDelegate >	addHandler,
		Action< TDelegate >	removeHandler
	)

static

Type Constraints

TEventArgs

:

EventArgs

◆ OnErrorRetry< TSource >()

static IObservable< TSource > UniRx.Observable.OnErrorRetry< TSource > ( this IObservable< TSource > source )

static

Repeats the source observable sequence until it successfully terminates.

This is same as Retry().

◆ OnErrorRetry< TSource, TException >() [1/5]

static IObservable< TSource > UniRx.Observable.OnErrorRetry< TSource, TException >	(	this IObservable< TSource >	source,
		Action< TException >	onError
	)

static

When catched exception, do onError action and repeat observable sequence.

Type Constraints

TException

:

Exception

◆ OnErrorRetry< TSource, TException >() [2/5]

static IObservable< TSource > UniRx.Observable.OnErrorRetry< TSource, TException >	(	this IObservable< TSource >	source,
		Action< TException >	onError,
		int	retryCount
	)

static

When catched exception, do onError action and repeat observable sequence during within retryCount.

Type Constraints

TException

:

Exception

◆ OnErrorRetry< TSource, TException >() [3/5]

static IObservable< TSource > UniRx.Observable.OnErrorRetry< TSource, TException >	(	this IObservable< TSource >	source,
		Action< TException >	onError,
		int	retryCount,
		TimeSpan	delay
	)

static

When catched exception, do onError action and repeat observable sequence after delay time during within retryCount.

Type Constraints

TException

:

Exception

◆ OnErrorRetry< TSource, TException >() [4/5]

static IObservable< TSource > UniRx.Observable.OnErrorRetry< TSource, TException >	(	this IObservable< TSource >	source,
		Action< TException >	onError,
		int	retryCount,
		TimeSpan	delay,
		IScheduler	delayScheduler
	)

static

When catched exception, do onError action and repeat observable sequence after delay time(work on delayScheduler) during within retryCount.

Type Constraints

TException

:

Exception

◆ OnErrorRetry< TSource, TException >() [5/5]

static IObservable< TSource > UniRx.Observable.OnErrorRetry< TSource, TException >	(	this IObservable< TSource >	source,
		Action< TException >	onError,
		TimeSpan	delay
	)

static

When catched exception, do onError action and repeat observable sequence after delay time.

Type Constraints

TException

:

Exception

◆ WhenAll() [1/2]

static IObservable< Unit > UniRx.Observable.WhenAll ( params IObservable< Unit >[] sources )

static

Specialized for single async operations like Task.WhenAll, Zip.Take(1).

◆ WhenAll() [2/2]

static IObservable< Unit > UniRx.Observable.WhenAll ( this IEnumerable< IObservable< Unit > > sources )

static

Specialized for single async operations like Task.WhenAll, Zip.Take(1).

◆ WhenAll< T >() [1/2]

static IObservable< T[]> UniRx.Observable.WhenAll< T > ( params IObservable< T >[] sources )

static

Specialized for single async operations like Task.WhenAll, Zip.Take(1).

If sequence is empty, return T[0] array.

◆ WhenAll< T >() [2/2]

static IObservable< T[]> UniRx.Observable.WhenAll< T > ( this IEnumerable< IObservable< T > > sources )

static

Specialized for single async operations like Task.WhenAll, Zip.Take(1).

If sequence is empty, return T[0] array.

The documentation for this class was generated from the following files:

RefCountDisposable.cs
Observable.cs
Observable.Unity.cs
Observable.Aggregate.cs
Observable.Binding.cs
Observable.Blocking.cs
Observable.Concatenate.cs
Observable.Concurrency.cs
Observable.Conversions.cs
Observable.Creation.cs
Observable.ErrorHandling.cs
Observable.Events.cs
Observable.FromAsync.cs
Observable.Paging.cs
Observable.Time.cs

Static Public Member Functions

Member Function Documentation

◆ Catch< T, TException >()

◆ CatchIgnore< TSource, TException >()

◆ FromEventPattern< TDelegate, TEventArgs >()

◆ OnErrorRetry< TSource >()

◆ OnErrorRetry< TSource, TException >() [1/5]

◆ OnErrorRetry< TSource, TException >() [2/5]

◆ OnErrorRetry< TSource, TException >() [3/5]

◆ OnErrorRetry< TSource, TException >() [4/5]

◆ OnErrorRetry< TSource, TException >() [5/5]

◆ WhenAll() [1/2]

◆ WhenAll() [2/2]

◆ WhenAll< T >() [1/2]

◆ WhenAll< T >() [2/2]