Observable 类

继承层次结构

System.Object
  Microsoft.Phone.Reactive.Observable

命名空间：  Microsoft.Phone.Reactive
程序集：  Microsoft.Phone.Reactive（在 Microsoft.Phone.Reactive.dll 中）

语法

声明
<ExtensionAttribute> _
Public NotInheritable Class Observable

public static class Observable

[ExtensionAttribute]
public ref class Observable abstract sealed

[<AbstractClass>]
[<Sealed>]
type Observable =  class end

Observable 类型公开以下成员。

方法

	名称	说明
	Aggregate<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>)
	Aggregate<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>)
	All<TSource>
	Amb<TSource>(IEnumerable<IObservable<TSource>>)
	Amb<TSource>(array<IObservable<TSource>[])
	Amb<TSource>(IObservable<TSource>, IObservable<TSource>)
	And<TLeft, TRight>
	Any<TSource>(IObservable<TSource>)
	Any<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
	AsObservable<TSource>
	Average(IObservable<Decimal>)
	Average(IObservable<Nullable<Decimal>>)
	Average(IObservable<Double>)
	Average(IObservable<Nullable<Double>>)
	Average(IObservable<Int32>)
	Average(IObservable<Nullable<Int32>>)
	Average(IObservable<Int64>)
	Average(IObservable<Nullable<Int64>>)
	Average(IObservable<Nullable<Single>>)
	Average(IObservable<Single>)
	BufferWithCount<TSource>(IObservable<TSource>, Int32)
	BufferWithCount<TSource>(IObservable<TSource>, Int32, Int32)
	BufferWithTime<TSource>(IObservable<TSource>, TimeSpan)
	BufferWithTime<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
	BufferWithTime<TSource>(IObservable<TSource>, TimeSpan, TimeSpan)
	BufferWithTime<TSource>(IObservable<TSource>, TimeSpan, TimeSpan, IScheduler)
	BufferWithTimeOrCount<TSource>(IObservable<TSource>, TimeSpan, Int32)
	BufferWithTimeOrCount<TSource>(IObservable<TSource>, TimeSpan, Int32, IScheduler)
	Case<TValue, TResult>(Func<TValue>, IDictionary<TValue, IObservable<TResult>>)
	Case<TValue, TResult>(Func<TValue>, IDictionary<TValue, IObservable<TResult>>, IScheduler)
	Case<TValue, TResult>(Func<TValue>, IDictionary<TValue, IObservable<TResult>>, IObservable<TResult>)
	Cast<TResult>
	Catch<TSource>(IEnumerable<IObservable<TSource>>)
	Catch<TSource>(array<IObservable<TSource>[])
	Catch<TSource>(IObservable<TSource>, IObservable<TSource>)
	Catch<TSource, TException>(IObservable<TSource>, Func<TException, IObservable<TSource>>)
	CombineLatest<TLeft, TRight, TResult>
	Concat<TSource>(IEnumerable<IObservable<TSource>>)
	Concat<TSource>(array<IObservable<TSource>[])
	Concat<TSource>(IObservable<TSource>, IObservable<TSource>)
	Contains<TSource>(IObservable<TSource>, TSource)
	Contains<TSource>(IObservable<TSource>, TSource, IEqualityComparer<TSource>)
	Count<TSource>
	Create<TSource>
	CreateWithDisposable<TSource>
	Defer<TValue>
	Delay<TSource>(IObservable<TSource>, DateTimeOffset)
	Delay<TSource>(IObservable<TSource>, TimeSpan)
	Delay<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
	Delay<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
	Dematerialize<TSource>
	DistinctUntilChanged<TSource>(IObservable<TSource>)
	DistinctUntilChanged<TSource>(IObservable<TSource>, IEqualityComparer<TSource>)
	DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
	DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
	Do<TSource>(IObservable<TSource>, Action<TSource>)
	Do<TSource>(IObservable<TSource>, IObserver<TSource>)
	Do<TSource>(IObservable<TSource>, Action<TSource>, Action)
	Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>)
	Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>, Action)
	DoWhile<TSource>
	Empty<TValue>()
	Empty<TValue>(IScheduler)
	Finally<TSource>
	First<TSource>
	FirstOrDefault<TSource>
	For<TSource, TResult>
	ForkJoin<TSource>(IEnumerable<IObservable<TSource>>)
	ForkJoin<TSource>(array<IObservable<TSource>[])
	ForkJoin<TLeft, TRight, TResult>(IObservable<TLeft>, IObservable<TRight>, Func<TLeft, TRight, TResult>)
	FromAsyncPattern(Func<AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>)
	FromAsyncPattern<TResult>(Func<AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>)
	FromAsyncPattern<T1>(Func<T1, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>)
	FromAsyncPattern<T1, TResult>(Func<T1, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>)
	FromAsyncPattern<T1, T2>(Func<T1, T2, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>)
	FromAsyncPattern<T1, T2, TResult>(Func<T1, T2, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>)
	FromAsyncPattern<T1, T2, T3>(Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>)
	FromAsyncPattern<T1, T2, T3, TResult>(Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>)
	FromAsyncPattern<T1, T2, T3, T4>(Func<T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>)
	FromAsyncPattern<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>)
	FromAsyncPattern<T1, T2, T3, T4, T5>(Func<T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>)
	FromAsyncPattern<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>)
	FromEvent<TEventArgs>(Action<EventHandler<TEventArgs>>, Action<EventHandler<TEventArgs>>)
	FromEvent<TEventArgs>(Object, String)
	FromEvent<TDelegate, TEventArgs>(Func<EventHandler<TEventArgs>, TDelegate>, Action<TDelegate>, Action<TDelegate>)
	Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TState>)
	Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TState>, IScheduler)
	GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, DateTimeOffset>, Func<TState, TState>)
	GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TimeSpan>, Func<TState, TState>)
	GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, DateTimeOffset>, Func<TState, TState>, IScheduler)
	GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TimeSpan>, Func<TState, TState>, IScheduler)
	GetEnumerator<TSource>
	GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
	GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
	GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)
	GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>)
	If<TResult>
	Interval(TimeSpan)
	Interval(TimeSpan, IScheduler)
	IsEmpty<TSource>
	Join<TResult>(IEnumerable<Plan<TResult>>)
	Join<TResult>(array<Plan<TResult>[])
	Last<TSource>
	LastOrDefault<TSource>
	Latest<TSource>
	Let<TValue, TResult>(TValue, Func<TValue, IObservable<TResult>>)
	Let<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
	LongCount<TSource>
	Materialize<TSource>
	Max(IObservable<Decimal>)
	Max(IObservable<Nullable<Decimal>>)
	Max(IObservable<Double>)
	Max(IObservable<Nullable<Double>>)
	Max(IObservable<Int32>)
	Max(IObservable<Nullable<Int32>>)
	Max(IObservable<Int64>)
	Max(IObservable<Nullable<Int64>>)
	Max(IObservable<Nullable<Single>>)
	Max(IObservable<Single>)
	Max<TSource>(IObservable<TSource>)
	Max<TSource>(IObservable<TSource>, IComparer<TSource>)
	MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
	MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>)
	Merge<TSource>(IEnumerable<IObservable<TSource>>)
	Merge<TSource>(IObservable<IObservable<TSource>>)
	Merge<TSource>(array<IObservable<TSource>[])
	Merge<TSource>(IEnumerable<IObservable<TSource>>, IScheduler)
	Merge<TSource>(IObservable<TSource>, IObservable<TSource>)
	Merge<TSource>(IScheduler, array<IObservable<TSource>[])
	Merge<TSource>(IObservable<TSource>, IObservable<TSource>, IScheduler)
	Min(IObservable<Decimal>)
	Min(IObservable<Nullable<Decimal>>)
	Min(IObservable<Double>)
	Min(IObservable<Nullable<Double>>)
	Min(IObservable<Int32>)
	Min(IObservable<Nullable<Int32>>)
	Min(IObservable<Int64>)
	Min(IObservable<Nullable<Int64>>)
	Min(IObservable<Nullable<Single>>)
	Min(IObservable<Single>)
	Min<TSource>(IObservable<TSource>)
	Min<TSource>(IObservable<TSource>, IComparer<TSource>)
	MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
	MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>)
	MostRecent<TSource>
	Never<TValue>
	Next<TSource>
	ObserveOn<TSource>(IObservable<TSource>, DispatcherScheduler)
	ObserveOn<TSource>(IObservable<TSource>, IScheduler)
	ObserveOn<TSource>(IObservable<TSource>, SynchronizationContext)
	ObserveOnDispatcher<TSource>
	OfType<TResult>
	OnErrorResumeNext<TSource>(IEnumerable<IObservable<TSource>>)
	OnErrorResumeNext<TSource>(array<IObservable<TSource>[])
	OnErrorResumeNext<TSource>(IObservable<TSource>, IObservable<TSource>)
	Prune<TSource>(IObservable<TSource>)
	Prune<TSource>(IObservable<TSource>, IScheduler)
	Prune<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
	Prune<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, IScheduler)
	Publish<TSource>(IObservable<TSource>)
	Publish<TSource>(IObservable<TSource>, TSource)
	Publish<TSource>(IObservable<TSource>, TSource, IScheduler)
	Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
	Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TSource)
	Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TSource, IScheduler)
	Range(Int32, Int32)
	Range(Int32, Int32, IScheduler)
	RefCount<TSource>
	RemoveTimeInterval<TSource>
	RemoveTimestamp<TSource>
	Repeat<TValue>(TValue)
	Repeat<TSource>(IObservable<TSource>)
	Repeat<TValue>(TValue, IScheduler)
	Repeat<TValue>(TValue, Int32)
	Repeat<TSource>(IObservable<TSource>, Int32)
	Repeat<TValue>(TValue, Int32, IScheduler)
	Replay<TSource>(IObservable<TSource>)
	Replay<TSource>(IObservable<TSource>, IScheduler)
	Replay<TSource>(IObservable<TSource>, Int32)
	Replay<TSource>(IObservable<TSource>, TimeSpan)
	Replay<TSource>(IObservable<TSource>, Int32, IScheduler)
	Replay<TSource>(IObservable<TSource>, Int32, TimeSpan)
	Replay<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
	Replay<TSource>(IObservable<TSource>, Int32, TimeSpan, IScheduler)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, IScheduler)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, IScheduler)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan, IScheduler)
	Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan, IScheduler)
	Retry<TSource>(IObservable<TSource>)
	Retry<TSource>(IObservable<TSource>, Int32)
	Return<TValue>(TValue)
	Return<TValue>(TValue, IScheduler)
	Run<TSource>(IObservable<TSource>)
	Run<TSource>(IObservable<TSource>, Action<TSource>)
	Run<TSource>(IObservable<TSource>, IObserver<TSource>)
	Run<TSource>(IObservable<TSource>, Action<TSource>, Action)
	Run<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>)
	Run<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>, Action)
	Sample<TSource>(IObservable<TSource>, TimeSpan)
	Sample<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
	Scan<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>)
	Scan<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>)
	Scan0<TSource, TAccumulate>
	Select<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>)
	Select<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, TResult>)
	SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>)
	SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>)
	SelectMany<TSource, TOther>(IObservable<TSource>, IObservable<TOther>)
	SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>)
	SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>)
	Single<TSource>
	SingleOrDefault<TSource>
	Skip<TSource>
	SkipLast<TSource>
	SkipUntil<TSource, TOther>
	SkipWhile<TSource>
	Start(Action)
	Start(Action, IScheduler)
	Start<TSource>(Func<TSource>)
	Start<TSource>(Func<TSource>, IScheduler)
	StartWith<TSource>(IObservable<TSource>, array<TSource[])
	StartWith<TSource>(IObservable<TSource>, IScheduler, array<TSource[])
	Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>)
	Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>, IScheduler)
	SubscribeOn<TSource>(IObservable<TSource>, DispatcherScheduler)
	SubscribeOn<TSource>(IObservable<TSource>, IScheduler)
	SubscribeOn<TSource>(IObservable<TSource>, SynchronizationContext)
	SubscribeOnDispatcher<TSource>
	Sum(IObservable<Decimal>)
	Sum(IObservable<Nullable<Decimal>>)
	Sum(IObservable<Double>)
	Sum(IObservable<Nullable<Double>>)
	Sum(IObservable<Int32>)
	Sum(IObservable<Nullable<Int32>>)
	Sum(IObservable<Int64>)
	Sum(IObservable<Nullable<Int64>>)
	Sum(IObservable<Nullable<Single>>)
	Sum(IObservable<Single>)
	Switch<TSource>
	Synchronize<TSource>(IObservable<TSource>)
	Synchronize<TSource>(IObservable<TSource>, Object)
	Take<TSource>(IObservable<TSource>, Int32)
	Take<TSource>(IObservable<TSource>, Int32, IScheduler)
	TakeLast<TSource>
	TakeUntil<TSource, TOther>
	TakeWhile<TSource>
	Then<TSource, TResult>
	Throttle<TSource>(IObservable<TSource>, TimeSpan)
	Throttle<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
	Throw<TValue>(Exception)
	Throw<TValue>(Exception, IScheduler)
	TimeInterval<TSource>(IObservable<TSource>)
	TimeInterval<TSource>(IObservable<TSource>, IScheduler)
	Timeout<TSource>(IObservable<TSource>, DateTimeOffset)
	Timeout<TSource>(IObservable<TSource>, TimeSpan)
	Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
	Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>)
	Timeout<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
	Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>)
	Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>, IScheduler)
	Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>, IScheduler)
	Timer(DateTimeOffset)
	Timer(TimeSpan)
	Timer(DateTimeOffset, IScheduler)
	Timer(DateTimeOffset, TimeSpan)
	Timer(TimeSpan, IScheduler)
	Timer(TimeSpan, TimeSpan)
	Timer(DateTimeOffset, TimeSpan, IScheduler)
	Timer(TimeSpan, TimeSpan, IScheduler)
	Timestamp<TSource>(IObservable<TSource>)
	Timestamp<TSource>(IObservable<TSource>, IScheduler)
	ToAsync(Action)
	ToAsync(Action, IScheduler)
	ToAsync<TSource>(Action<TSource>)
	ToAsync<TResult>(Func<TResult>)
	ToAsync<TSource>(Action<TSource>, IScheduler)
	ToAsync<TResult>(Func<TResult>, IScheduler)
	ToAsync<T1, T2>(Action<T1, T2>)
	ToAsync<T, TResult>(Func<T, TResult>)
	ToAsync<T1, T2>(Action<T1, T2>, IScheduler)
	ToAsync<T, TResult>(Func<T, TResult>, IScheduler)
	ToAsync<T1, T2, T3>(Action<T1, T2, T3>)
	ToAsync<T1, T2, TResult>(Func<T1, T2, TResult>)
	ToAsync<T1, T2, T3>(Action<T1, T2, T3>, IScheduler)
	ToAsync<T1, T2, TResult>(Func<T1, T2, TResult>, IScheduler)
	ToAsync<T1, T2, T3, T4>(Action<T1, T2, T3, T4>)
	ToAsync<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult>)
	ToAsync<T1, T2, T3, T4>(Action<T1, T2, T3, T4>, IScheduler)
	ToAsync<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult>, IScheduler)
	ToAsync<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5>)
	ToAsync<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult>)
	ToAsync<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5>, IScheduler)
	ToAsync<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult>, IScheduler)
	ToAsync<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult>)
	ToAsync<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult>, IScheduler)
	ToEnumerable<TSource>
	ToObservable<TSource>(IEnumerable<TSource>)
	ToObservable<TSource>(IEnumerable<TSource>, IScheduler)
	Using<TSource, TResource>
	Where<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
	Where<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>)
	While<TSource>
	Zip<TLeft, TRight, TResult>(IObservable<TLeft>, IEnumerable<TRight>, Func<TLeft, TRight, TResult>)
	Zip<TLeft, TRight, TResult>(IObservable<TLeft>, IObservable<TRight>, Func<TLeft, TRight, TResult>)

页首

版本信息

适用于 Windows Phone 应用的 .NET

受以下版本支持：Windows Phone 8、Silverlight 8.1

线程安全

此类型的任何公共 static（在 Visual Basic 中为 Shared） 成员都是线程安全的。但不保证所有实例成员都是线程安全的。

请参阅

参考

Microsoft.Phone.Reactive 命名空间