ISubject<T1, T2> 接口

命名空间:  Microsoft.Phone.Reactive
程序集:  Microsoft.Phone.Reactive(在 Microsoft.Phone.Reactive.dll 中)

语法

声明
Public Interface ISubject(Of In T1, Out T2) _
    Inherits IObserver(Of T1), IObservable(Of T2)
public interface ISubject<in T1, out T2> : IObserver<T1>, 
    IObservable<T2>
generic<typename T1, typename T2>
public interface class ISubject : IObserver<T1>, 
    IObservable<T2>
type ISubject<'T1, 'T2> =  
    interface
        interface IObserver<'T1>
        interface IObservable<'T2>
    end

类型参数

  • in T1
    此类型参数是逆变。即可以使用指定的类型或派生程度更低的类型。有关协变和逆变的详细信息,请参阅泛型中的协变和逆变
  • out T2
    此类型参数是协变。即可以使用指定的类型或派生程度更高的类型。有关协变和逆变的详细信息,请参阅泛型中的协变和逆变

ISubject<T1, T2> 类型公开以下成员。

方法

  名称 说明
公共方法 OnCompleted 通知观察者,提供程序已完成发送基于推送的通知。 (继承自 IObserver<T>。)
公共方法 OnError 通知观察者,提供程序遇到错误情况。 (继承自 IObserver<T>。)
公共方法 OnNext 向观察者提供新数据。 (继承自 IObserver<T>。)
公共方法 Subscribe 通知提供程序:某观察程序将要接收通知。 (继承自 IObservable<T>。)

页首

扩展方法 

  名称 说明
公共扩展方法 Aggregate<T2>(Func<T2, T2, T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Aggregate<T2, TAccumulate>(TAccumulate, Func<TAccumulate, T2, TAccumulate>) 已重载。 (由 Observable 定义。)
公共扩展方法 All<T2> (由 Observable 定义。)
公共扩展方法 Amb<T2> (由 Observable 定义。)
公共扩展方法 And<T2, TRight> (由 Observable 定义。)
公共扩展方法 Any<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Any<T2>(Func<T2, Boolean>) 已重载。 (由 Observable 定义。)
公共扩展方法 AsObservable<T2> (由 Observable 定义。)
公共扩展方法 AsObserver<T1> (由 Observer 定义。)
公共扩展方法 BufferWithCount<T2>(Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithCount<T2>(Int32, Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithTime<T2>(TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithTime<T2>(TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithTime<T2>(TimeSpan, TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithTime<T2>(TimeSpan, TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithTimeOrCount<T2>(TimeSpan, Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 BufferWithTimeOrCount<T2>(TimeSpan, Int32, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Catch<T2>(IObservable<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Catch<T2, TException>(Func<TException, IObservable<T2>>) 已重载。 (由 Observable 定义。)
公共扩展方法 CombineLatest<T2, TRight, TResult> (由 Observable 定义。)
公共扩展方法 Concat<T2> (由 Observable 定义。)
公共扩展方法 Contains<T2>(T2) 已重载。 (由 Observable 定义。)
公共扩展方法 Contains<T2>(T2, IEqualityComparer<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Count<T2> (由 Observable 定义。)
公共扩展方法 Delay<T2>(DateTimeOffset) 已重载。 (由 Observable 定义。)
公共扩展方法 Delay<T2>(TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Delay<T2>(DateTimeOffset, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Delay<T2>(TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 DistinctUntilChanged<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 DistinctUntilChanged<T2>(IEqualityComparer<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 DistinctUntilChanged<T2, TKey>(Func<T2, TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 DistinctUntilChanged<T2, TKey>(Func<T2, TKey>, IEqualityComparer<TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 Do<T2>(Action<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Do<T2>(IObserver<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Do<T2>(Action<T2>, Action) 已重载。 (由 Observable 定义。)
公共扩展方法 Do<T2>(Action<T2>, Action<Exception>) 已重载。 (由 Observable 定义。)
公共扩展方法 Do<T2>(Action<T2>, Action<Exception>, Action) 已重载。 (由 Observable 定义。)
公共扩展方法 Finally<T2> (由 Observable 定义。)
公共扩展方法 First<T2> (由 Observable 定义。)
公共扩展方法 FirstOrDefault<T2> (由 Observable 定义。)
公共扩展方法 ForkJoin<T2, TRight, TResult> (由 Observable 定义。)
公共扩展方法 GetEnumerator<T2> (由 Observable 定义。)
公共扩展方法 GroupBy<T2, TKey>(Func<T2, TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 GroupBy<T2, TKey>(Func<T2, TKey>, IEqualityComparer<TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 GroupBy<T2, TKey, TElement>(Func<T2, TKey>, Func<T2, TElement>) 已重载。 (由 Observable 定义。)
公共扩展方法 GroupBy<T2, TKey, TElement>(Func<T2, TKey>, Func<T2, TElement>, IEqualityComparer<TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 IsEmpty<T2> (由 Observable 定义。)
公共扩展方法 Last<T2> (由 Observable 定义。)
公共扩展方法 LastOrDefault<T2> (由 Observable 定义。)
公共扩展方法 Latest<T2> (由 Observable 定义。)
公共扩展方法 Let<T2, TResult> (由 Observable 定义。)
公共扩展方法 LongCount<T2> (由 Observable 定义。)
公共扩展方法 Materialize<T2> (由 Observable 定义。)
公共扩展方法 Max<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Max<T2>(IComparer<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 MaxBy<T2, TKey>(Func<T2, TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 MaxBy<T2, TKey>(Func<T2, TKey>, IComparer<TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 Merge<T2>(IObservable<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Merge<T2>(IObservable<T2>, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Min<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Min<T2>(IComparer<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 MinBy<T2, TKey>(Func<T2, TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 MinBy<T2, TKey>(Func<T2, TKey>, IComparer<TKey>) 已重载。 (由 Observable 定义。)
公共扩展方法 MostRecent<T2> (由 Observable 定义。)
公共扩展方法 Next<T2> (由 Observable 定义。)
公共扩展方法 ObserveOn<T2>(Dispatcher) 已重载。 (由 DispatcherObservableExtensions 定义。)
公共扩展方法 ObserveOn<T2>(DispatcherScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 ObserveOn<T2>(IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 ObserveOn<T2>(SynchronizationContext) 已重载。 (由 Observable 定义。)
公共扩展方法 ObserveOnDispatcher<T2> (由 Observable 定义。)
公共扩展方法 OnErrorResumeNext<T2> (由 Observable 定义。)
公共扩展方法 Prune<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Prune<T2>(IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Prune<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>) 已重载。 (由 Observable 定义。)
公共扩展方法 Prune<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Publish<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Publish<T2>(T2) 已重载。 (由 Observable 定义。)
公共扩展方法 Publish<T2>(T2, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Publish<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>) 已重载。 (由 Observable 定义。)
公共扩展方法 Publish<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, T2) 已重载。 (由 Observable 定义。)
公共扩展方法 Publish<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, T2, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Repeat<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Repeat<T2>(Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(Int32, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(Int32, TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2>(Int32, TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, Int32, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, Int32, TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Replay<T2, TResult>(Func<IObservable<T2>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Retry<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Retry<T2>(Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 Run<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Run<T2>(Action<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Run<T2>(IObserver<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Run<T2>(Action<T2>, Action) 已重载。 (由 Observable 定义。)
公共扩展方法 Run<T2>(Action<T2>, Action<Exception>) 已重载。 (由 Observable 定义。)
公共扩展方法 Run<T2>(Action<T2>, Action<Exception>, Action) 已重载。 (由 Observable 定义。)
公共扩展方法 Sample<T2>(TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Sample<T2>(TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Scan<T2>(Func<T2, T2, T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Scan<T2, TAccumulate>(TAccumulate, Func<TAccumulate, T2, TAccumulate>) 已重载。 (由 Observable 定义。)
公共扩展方法 Scan0<T2, TAccumulate> (由 Observable 定义。)
公共扩展方法 Select<T2, TResult>(Func<T2, TResult>) 已重载。 (由 Observable 定义。)
公共扩展方法 Select<T2, TResult>(Func<T2, Int32, TResult>) 已重载。 (由 Observable 定义。)
公共扩展方法 SelectMany<T2, TResult>(Func<T2, IObservable<TResult>>) 已重载。 (由 Observable 定义。)
公共扩展方法 SelectMany<T2, TResult>(Func<T2, IEnumerable<TResult>>) 已重载。 (由 Observable 定义。)
公共扩展方法 SelectMany<T2, TOther>(IObservable<TOther>) 已重载。 (由 Observable 定义。)
公共扩展方法 SelectMany<T2, TResult>(Func<T2, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) 已重载。 (由 Observable 定义。)
公共扩展方法 SelectMany<T2, TCollection, TResult>(Func<T2, IObservable<TCollection>>, Func<T2, TCollection, TResult>) 已重载。 (由 Observable 定义。)
公共扩展方法 Single<T2> (由 Observable 定义。)
公共扩展方法 SingleOrDefault<T2> (由 Observable 定义。)
公共扩展方法 Skip<T2> (由 Observable 定义。)
公共扩展方法 SkipLast<T2> (由 Observable 定义。)
公共扩展方法 SkipUntil<T2, TOther> (由 Observable 定义。)
公共扩展方法 SkipWhile<T2> (由 Observable 定义。)
公共扩展方法 StartWith<T2>(array<T2[]) 已重载。 (由 Observable 定义。)
公共扩展方法 StartWith<T2>(IScheduler, array<T2[]) 已重载。 (由 Observable 定义。)
公共扩展方法 Subscribe<T2>() 已重载。 (由 ObservableExtensions 定义。)
公共扩展方法 Subscribe<T2>(Action<T2>) 已重载。 (由 ObservableExtensions 定义。)
公共扩展方法 Subscribe<T2>(Action<T2>, Action<Exception>) 已重载。 (由 ObservableExtensions 定义。)
公共扩展方法 Subscribe<T2>(Action<T2>, Action) 已重载。 (由 ObservableExtensions 定义。)
公共扩展方法 Subscribe<T2>(Action<T2>, Action<Exception>, Action) 已重载。 (由 ObservableExtensions 定义。)
公共扩展方法 SubscribeOn<T2>(Dispatcher) 已重载。 (由 DispatcherObservableExtensions 定义。)
公共扩展方法 SubscribeOn<T2>(DispatcherScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 SubscribeOn<T2>(IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 SubscribeOn<T2>(SynchronizationContext) 已重载。 (由 Observable 定义。)
公共扩展方法 SubscribeOnDispatcher<T2> (由 Observable 定义。)
公共扩展方法 Synchronize<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Synchronize<T2>(Object) 已重载。 (由 Observable 定义。)
公共扩展方法 Take<T2>(Int32) 已重载。 (由 Observable 定义。)
公共扩展方法 Take<T2>(Int32, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 TakeLast<T2> (由 Observable 定义。)
公共扩展方法 TakeUntil<T2, TOther> (由 Observable 定义。)
公共扩展方法 TakeWhile<T2> (由 Observable 定义。)
公共扩展方法 Then<T2, TResult> (由 Observable 定义。)
公共扩展方法 Throttle<T2>(TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Throttle<T2>(TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 TimeInterval<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 TimeInterval<T2>(IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(DateTimeOffset) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(TimeSpan) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(DateTimeOffset, IObservable<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(DateTimeOffset, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(TimeSpan, IObservable<T2>) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(TimeSpan, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(DateTimeOffset, IObservable<T2>, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Timeout<T2>(TimeSpan, IObservable<T2>, IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 Timestamp<T2>() 已重载。 (由 Observable 定义。)
公共扩展方法 Timestamp<T2>(IScheduler) 已重载。 (由 Observable 定义。)
公共扩展方法 ToEnumerable<T2> (由 Observable 定义。)
公共扩展方法 ToNotifier<T1> (由 Observer 定义。)
公共扩展方法 Where<T2>(Func<T2, Boolean>) 已重载。 (由 Observable 定义。)
公共扩展方法 Where<T2>(Func<T2, Int32, Boolean>) 已重载。 (由 Observable 定义。)
公共扩展方法 Zip<T2, TRight, TResult>(IEnumerable<TRight>, Func<T2, TRight, TResult>) 已重载。 (由 Observable 定义。)
公共扩展方法 Zip<T2, TRight, TResult>(IObservable<TRight>, Func<T2, TRight, TResult>) 已重载。 (由 Observable 定义。)

页首

版本信息

适用于 Windows Phone 应用的 .NET

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

请参阅

参考

Microsoft.Phone.Reactive 命名空间