IGroupedObservable<TKey, TElement> 接口

表示具有通用键的可观察值序列。

Namespace:System.Reactive.Linq
装配: System.Reactive.dll) 中的 System.Reactive (

语法

'Declaration
Public Interface IGroupedObservable(Of Out TKey, Out TElement) _
    Inherits IObservable(Of TElement)
'Usage
Dim instance As IGroupedObservable(Of Out TKey, Out TElement)
public interface IGroupedObservable<out TKey, out TElement> : IObservable<TElement>
generic<typename TKey, typename TElement>
public interface class IGroupedObservable : IObservable<TElement>
type IGroupedObservable<'TKey, 'TElement> =  
    interface
        interface IObservable<'TElement>
    end
JScript does not support generic types and methods.

类型参数

  • outTKey
    键的类型。

    这是协变类型参数。 即,可以使用指定的类型,也可以使用派生程度较高的任何类型。 有关协变和逆变的详细信息,请参阅

  • outTElement
    元素的类型。

IGroupedObservable<TKey、 TElement> 类型公开以下成员。

属性

  名称 说明
公共属性 Key 获取公共键。

顶部

方法

  名称 说明
Public method Public method 订阅 (继承自 IObservable<TElement>.)

顶部

扩展方法

  名称 说明
公共扩展方法 聚合<TElement> (Func<TElement、TElement、TElement>) 已重载。 对可观测序列应用累加器函数。 由 Observable.) 定义的 (
公共扩展方法 聚合<TElement、TAccumulate> (TAccumulate、Func<TAccumulate、TElement、TAccumulate>) 已重载。 对具有指定种子值的可观测序列应用累加器函数。 由 Observable.) 定义的 (
公共扩展方法 所有<TElement> 确定可观测序列的所有元素是否都满足某个条件。 由 Observable.) 定义的 (
公共扩展方法 Amb<TElement> 传播可观测序列,该序列首先使用指定的第一个和第二个序列做出反应。 由 Observable.) 定义的 (
公共扩展方法 TElement<、TRight> 当两个可观测序列都有可用值时匹配。 由 Observable.) 定义的 (
公共扩展方法 Any<TElement> () 已重载。 确定可观测序列是否包含任何元素。 由 Observable.) 定义的 (
公共扩展方法 任何<TElement> (Func<TElement、布尔) > 已重载。 确定可观测序列的所有元素是否都满足某个条件。 由 Observable.) 定义的 (
公共扩展方法 AsObservable<TElement> 隐藏可观测序列的标识。 由 Observable.) 定义的 (
公共扩展方法 AsQbservable<TElement> 将可观测序列转换为可查询的可观测序列。 由 Qbservable.) 定义的 (
公共扩展方法 AssertEqual<TElement> Extensions.) 定义的 (
公共扩展方法 Buffer<TElement> (Int32) 已重载。 指示可观测序列的每个元素进入基于元素计数信息生成的连续非重叠缓冲区。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (TimeSpan) 已重载。 指示可观测序列的每个元素进入基于计时信息生成的连续非重叠缓冲区。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (Int32、Int32) 已重载。 指示可观测序列的每个元素成零个或多个缓冲区,这些缓冲区基于元素计数信息生成。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (TimeSpan、IScheduler) 已重载。 指示可观测序列的每个元素进入基于计时信息生成的连续非重叠缓冲区。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (TimeSpan、TimeSpan) 已重载。 将可观测序列的每个元素指示为基于计时信息生成的零个或多个缓冲区。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (TimeSpan、Int32) 已重载。 指示可观测序列的每个元素进入缓冲区,该缓冲区在已满或经过给定时间量时发出。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (TimeSpan、TimeSpan、IScheduler) 已重载。 指示可观测序列的每个元素成零个或多个缓冲区,这些缓冲区基于计时信息生成。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement> (TimeSpan、Int32、IScheduler) 已重载。 指示可观测序列的每个元素进入缓冲区,该缓冲区在已满或经过给定时间量时发出。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement、TBufferClosing> (Func<IObservable<TBufferClosing>>) 已重载。 指示可观测序列的每个元素进入连续的非重叠缓冲区。 由 Observable.) 定义的 (
公共扩展方法 Buffer<TElement、TBufferOpening、TBufferClosing> (IObservable<TBufferOpening>、Func<TBufferOpening、IObservable<TBufferClosing>>) 已重载。 指示可查询可观测序列的每个元素进入连续的非重叠缓冲区。 由 Observable.) 定义的 (
公共扩展方法 捕获<TElement> (IObservable<TElement>) 已重载。 继续由异常终止的可观测序列,该序列与下一个可观察序列一起终止。 由 Observable.) 定义的 (
公共扩展方法 捕获<TElement、TException> (Func<TException、IObservable<TElement>>) 已重载。 使用处理程序生成的可观察序列继续由指定类型的异常终止的可观察序列。 由 Observable.) 定义的 (
公共扩展方法 CombineLatest<TElement、TSecond、TResult> 每当其中一个可观测序列生成元素时,使用选择器函数将两个可观测序列合并为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 Concat<TElement> 连接两个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 包含<TElement> (TElement) 已重载。 使用默认相等比较器确定可观测序列是否包含指定的元素。 由 Observable.) 定义的 (
公共扩展方法 包含<TElement> (TElement、IEqualityComparer<TElement>) 已重载。 通过使用指定的 System.Collections.Generic.IEqualityComparer&lt;确定可观测序列是否包含指定的元素;T&gt;. 由 Observable.) 定义的 (
公共扩展方法 计数<TElement> 返回一个 Int32 ,表示可观测序列中的元素总数。 由 Observable.) 定义的 (
公共扩展方法 DefaultIfEmpty<TElement> () 已重载。 如果序列为空,则返回指定序列的元素或类型参数在单一实例序列中的默认值。 由 Observable.) 定义的 (
公共扩展方法 DefaultIfEmpty<TElement> (TElement) 已重载。 如果序列为空,则返回指定序列的元素或类型参数在单一实例序列中的默认值。 由 Observable.) 定义的 (
公共扩展方法 延迟<TElement> (TimeSpan) 已重载。 使用指定的源和 dueTime 按到期时间指示可观测序列。 由 Observable.) 定义的 (
公共扩展方法 延迟<TElement> (DateTimeOffset) 已重载。 使用指定的源和 dueTime 按到期时间指示可观测序列。 由 Observable.) 定义的 (
公共扩展方法 延迟<TElement> (TimeSpan、IScheduler) 已重载。 使用指定的源、dueTime 和计划程序指示按到期时间的可观测序列。 由 Observable.) 定义的 (
公共扩展方法 延迟<TElement> (DateTimeOffset、IScheduler) 已重载。 使用指定的源、dueTime 和计划程序指示按到期时间的可观测序列。 由 Observable.) 定义的 (
公共扩展方法 Distinct<TElement> () 已重载。 返回一个可观测序列,该序列仅包含具有指定源的不同元素。 由 Observable.) 定义的 (
公共扩展方法 Distinct<TElement> (IEqualityComparer<TElement>) 已重载。 根据比较器返回仅包含不同元素的可观测序列。 由 Observable.) 定义的 (
公共扩展方法 Distinct<TElement、TKey> (Func<TElement、TKey>) 已重载。 返回一个可观测序列,该序列仅包含根据 keySelector 的不同元素。 由 Observable.) 定义的 (
公共扩展方法 Distinct<TElement、TKey> (Func<TElement、TKey>、IEqualityComparer<TKey>) 已重载。 返回一个可观测序列,该序列仅包含根据 keySelector 的不同元素。 由 Observable.) 定义的 (
公共扩展方法 DistinctUntilChanged<TElement> () 已重载。 返回一个可观测序列,该序列仅包含具有指定源的不同连续元素。 由 Observable.) 定义的 (
公共扩展方法 DistinctUntilChanged<TElement> (IEqualityComparer<TElement>) 已重载。 返回一个可观测序列,该序列仅包含根据比较器的不同连续元素。 由 Observable.) 定义的 (
公共扩展方法 DistinctUntilChanged<TElement、TKey> (Func<TElement、TKey>) 已重载。 返回一个可观测序列,该序列仅包含根据 keySelector 的不同连续元素。 由 Observable.) 定义的 (
公共扩展方法 DistinctUntilChanged<TElement、TKey> (Func<TElement、TKey>、IEqualityComparity<TKey>) 已重载。 根据 keySelector 和比较器返回一个可观测序列,该序列仅包含不同的连续元素。 由 Observable.) 定义的 (
公共扩展方法 执行<TElement> (操作<TElement>) 已重载。 为可观测序列中的每个元素调用一个操作。 由 Observable.) 定义的 (
公共扩展方法 TElement<> (IObserver<TElement>) 已重载。 为可观测序列中的每个元素调用一个操作,并在可观测序列异常终止时调用一个操作。 由 Observable.) 定义的 (
公共扩展方法 执行<TElement> (操作<TElement>、Action) 已重载。 为可观测序列中的每个元素调用一个操作,并在可观测序列正常终止时调用一个操作。 由 Observable.) 定义的 (
公共扩展方法 TElement<> (操作<TElement>、操作<异常>) 已重载。 为可观测序列中的每个元素调用一个操作,并在可观测序列异常终止时调用一个操作。 由 Observable.) 定义的 (
公共扩展方法 TElement<> (操作<TElement>、操作<异常>、操作) 已重载。 为可观测序列中的每个元素调用一个操作,并在可观测序列正常或异常终止时调用操作。 由 Observable.) 定义的 (
公共扩展方法 ElementAt<TElement> 返回序列中指定索引处的元素。 由 Observable.) 定义的 (
公共扩展方法 ElementAtOrDefault<TElement> 返回序列中指定索引处的元素;如果索引超出范围,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 最后<TElement> 在源可观测序列正常终止或由异常终止后调用指定的操作。 由 Observable.) 定义的 (
公共扩展方法 First<TElement> () 已重载。 返回具有指定源的可观测序列的第一个元素。 由 Observable.) 定义的 (
公共扩展方法 First<TElement> (Func<TElement,Boolean>) 已重载。 返回与谓词匹配的可观测序列的第一个元素。 由 Observable.) 定义的 (
公共扩展方法 FirstOrDefault<TElement> () 已重载。 返回可观测序列的第一个元素,如果未找到任何值,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 FirstOrDefault<TElement> (Func<TElement,Boolean>) 已重载。 返回与谓词匹配的可观测序列的第一个元素;如果未找到任何值,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 Foo<TElement,R> MyExt.) 定义的 (
公共扩展方法 ForEach<TElement> 为可观测序列中的每个元素调用一个操作,并在序列终止之前阻止。 由 Observable.) 定义的 (
公共扩展方法 GetEnumerator<TElement> 返回枚举器,该枚举器枚举可观测序列的所有值。 由 Observable.) 定义的 (
公共扩展方法 GroupBy<TElement、TKey> (Func<TElement、TKey>) 已重载。 根据指定的键选择器函数对可观测序列的元素进行分组。 由 Observable.) 定义的 (
公共扩展方法 GroupBy<TElement、TKey> (Func<TElement、TKey>、IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数和比较器对可观测序列的元素进行分组。 由 Observable.) 定义的 (
公共扩展方法 GroupBy<TElement、TKey、TElement> (Func<TElement、TKey>、Func<TElement、TElement>) 已重载。 对可观测序列的元素进行分组,并使用指定的函数选择生成的元素。 由 Observable.) 定义的 (
公共扩展方法 GroupBy<TElement、TKey、TElement> (Func<TElement、TKey>、Func<TElement、TElement>、IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数和比较器对可观测序列的元素进行分组,并使用指定的函数选择生成的元素。 由 Observable.) 定义的 (
公共扩展方法 GroupByUntil<TElement, TKey, TDuration> (Func<TElement, TKey>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>) 已重载。 根据指定的键选择器函数对可观测序列的元素进行分组。 由 Observable.) 定义的 (
公共扩展方法 GroupByUntil<TElement, TKey, TDuration> (Func<TElement, TKey>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数和比较器对可观测序列的元素进行分组。 由 Observable.) 定义的 (
公共扩展方法 GroupByUntil<TElement, TKey, TElement, TDuration> (Func<TElement, TKey>, Func<TElement, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>) 已重载。 根据指定的键选择器函数对可观测序列的元素进行分组,并使用指定的函数选择生成的元素。 由 Observable.) 定义的 (
公共扩展方法 GroupByUntil<TElement, TKey, TElement, TDuration> (Func<TElement, TKey>, Func<TElement, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数和比较器对可观测序列的元素进行分组,并使用指定的函数选择生成的元素。 由 Observable.) 定义的 (
公共扩展方法 GroupJoin<TElement、TRight、TLeftDuration、TRightDuration、TResult> 根据重叠持续时间关联两个序列的元素,并将结果分组。 由 Observable.) 定义的 (
公共扩展方法 IgnoreElements<TElement> 忽略可观测序列中的所有值,只保留终止消息。 由 Observable.) 定义的 (
公共扩展方法 Join<TElement、TRight、TLeftDuration、TRightDuration、TResult> 根据重叠持续时间关联两个序列的元素。 由 Observable.) 定义的 (
公共扩展方法 Last<TElement> () 已重载。 返回具有指定源的可观测序列的最后一个元素。 由 Observable.) 定义的 (
公共扩展方法 Last<TElement> (Func<TElement,布尔>) 已重载。 返回与谓词匹配的可观测序列的最后一个元素。 由 Observable.) 定义的 (
公共扩展方法 LastOrDefault<TElement> () 已重载。 返回可观测序列中的最后一个元素,如果未找到值,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 LastOrDefault<TElement> (Func<TElement,布尔>) 已重载。 返回与谓词匹配的可观察序列的最后一个元素;如果未找到任何值,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 最新<TElement> 对可观测序列中的最新值进行采样。 由 Observable.) 定义的 (
公共扩展方法 LongCount<TElement> 返回一个 Int64 ,表示可观测序列中的元素总数。 由 Observable.) 定义的 (
公共扩展方法 具体化<TElement> 将可观测序列的隐式通知具体化为显式通知值。 由 Observable.) 定义的 (
公共扩展方法 Max<TElement> () 已重载。 返回可观测序列中的最大元素。 由 Observable.) 定义的 (
公共扩展方法 最大<TElement> (IComparer<TElement>) 已重载。 根据指定的比较器返回可观测序列中的最大值。 由 Observable.) 定义的 (
公共扩展方法 MaxBy<TElement、TKey> (Func<TElement、TKey>) 已重载。 返回具有最大键值的可观测序列中的元素。 由 Observable.) 定义的 (
公共扩展方法 MaxBy<TElement、TKey> (Func<TElement、TKey>、IComparer<TKey>) 已重载。 返回具有最大键值的可观测序列中的元素。 由 Observable.) 定义的 (
公共扩展方法 合并<TElement> (IObservable<TElement>) 已重载。 将可观测序列的可观测序列合并到可观测序列中。 由 Observable.) 定义的 (
公共扩展方法 合并<TElement> (IObservable<TElement>、IScheduler) 已重载。 将两个可观测序列合并为单个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 最小<TElement> () 已重载。 返回可观测序列中的最小元素。 由 Observable.) 定义的 (
公共扩展方法 Min<TElement> (IComparer<TElement>) 已重载。 根据指定的比较器返回可观测序列中的最小值。 由 Observable.) 定义的 (
公共扩展方法 MinBy<TElement、TKey> (Func<TElement、TKey>) 已重载。 返回具有最小键值的可观测序列中的元素。 由 Observable.) 定义的 (
公共扩展方法 MinBy<TElement、TKey> (Func<TElement、TKey>、IComparer<TKey>) 已重载。 根据指定的比较器,返回具有最小键值的可观测序列中的元素。 由 Observable.) 定义的 (
公共扩展方法 MostRecent<TElement> 对可观测序列中的最新值进行采样。 由 Observable.) 定义的 (
公共扩展方法 多播<TElement、TResult> (ISubject<TElement、TResult>) 已重载。 返回一个可连接的可观察序列,该序列在连接时使源序列将结果推送到指定主题中。 由 Observable.) 定义的 (
公共扩展方法 多播<TElement、TIntermediate、TResult> (Func<ISubject<TElement、TIntermediate>>、Func<IObservable<TIntermediate>、IObservable<TResult>>) 已重载。 返回一个可观察序列,其中包含在选择器函数中多播源序列所生成的序列的元素。 由 Observable.) 定义的 (
公共扩展方法 Next<TElement> 采样下一个值 (阻塞,而不缓冲可观测序列中的) 。 由 Observable.) 定义的 (
公共扩展方法 ObserveOn<TElement> (SynchronizationContext) 已重载。 在指定的同步上下文中异步通知观察者。 由 Observable.) 定义的 (
公共扩展方法 ObserveOn<TElement> (Control) 已重载。 由 ControlObservable.) 定义的 (
公共扩展方法 ObserveOn<TElement> (Dispatcher) 已重载。 由 DispatcherObservable.) 定义的 (
公共扩展方法 ObserveOn<TElement> (DispatcherScheduler) 已重载。 由 DispatcherObservable.) 定义的 (
公共扩展方法 ObserveOn<TElement> (IScheduler) 已重载。 异步通知指定计划程序上的观察者。 由 Observable.) 定义的 (
公共扩展方法 ObserveOnDispatcher<TElement> DispatcherObservable.) 定义的 (
公共扩展方法 OnErrorResumeNext<TElement> 继续正常终止的可观察序列,或由下一个可观察序列的异常终止。 由 Observable.) 定义的 (
公共扩展方法 发布<TElement> () 已重载。 返回一个可连接的可观察序列,该序列共享基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 发布<TElement> (TElement) 已重载。 返回一个可连接的可观察序列,该序列共享对基础序列的单个订阅,以 initialValue 开头。 由 Observable.) 定义的 (
公共扩展方法 发布<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>) 已重载。 返回一个可观察序列,该序列是在共享基础序列的单个订阅的可连接可观测序列上调用选择器的结果。 由 Observable.) 定义的 (
公共扩展方法 发布<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、TElement) 已重载。 返回一个可连接的可观察序列,该序列共享对基础序列的单个订阅,以 initialValue 开头。 由 Observable.) 定义的 (
公共扩展方法 PublishLast<TElement> () 已重载。 返回一个可连接的可观察序列,该序列共享仅包含最后一个通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 PublishLast<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>) 已重载。 返回一个可观测序列,该序列是在可连接的可观测序列上调用选择器的结果,该序列共享仅包含最后一个通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重复<TElement> () 已重载。 无限期地重复可观测序列。 由 Observable.) 定义的 (
公共扩展方法 重复<TElement> (Int32) 已重载。 无限期地重复可观测序列。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> () 已重载。 返回一个可连接的可观察序列,该序列共享对重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (TimeSpan) 已重载。 返回一个可连接的可观察序列,该序列共享对窗口内重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (Int32) 已重载。 返回一个可连接的可观察序列,该序列共享对基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (IScheduler) 已重载。 返回一个可连接的可观察序列,该序列共享对重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (TimeSpan、IScheduler) 已重载。 返回一个可连接的可观察序列,该序列共享对窗口内重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (Int32、IScheduler) 已重载。 返回一个可连接的可观察序列,该序列共享对基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (Int32、TimeSpan) 已重载。 返回一个可连接的可观察序列,该序列共享对窗口内的基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement> (Int32、TimeSpan、IScheduler) 已重载。 返回一个可连接的可观察序列,该序列共享对窗口内的基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>) 已重载。 返回一个可观测序列,该序列是在可连接可观测序列上调用选择器的结果,该序列共享基础序列的单个订阅,以初始值开头。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、IScheduler) 已重载。 返回一个可观测序列,该序列是在可连接的可观测序列上调用选择器的结果,该序列共享对重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、TimeSpan) 已重载。 返回一个可观测序列,该序列是在可连接的可观察序列上调用选择器的结果,该序列共享对窗口内重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、Int32) 已重载。 返回一个可观察序列,该序列是在可连接的可观察序列上调用选择器的结果,该序列共享对基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、TimeSpan、IScheduler) 已重载。 返回一个可观测序列,该序列是在可连接的可观察序列上调用选择器的结果,该序列共享对窗口内重播所有通知的基础序列的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、Int32、IScheduler) 已重载。 返回一个可观察序列,该序列是在可连接的可观察序列上调用选择器的结果,该序列共享对基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、Int32、TimeSpan) 已重载。 返回一个可观察序列,该序列是在可连接的可观测序列上调用选择器的结果,该序列共享对窗口内的基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重播<TElement、TResult> (Func<IObservable<TElement>、IObservable<TResult>>、Int32、TimeSpan、IScheduler) 已重载。 返回一个可观察序列,该序列是在可连接的可观测序列上调用选择器的结果,该序列共享对窗口内的基础序列重播 bufferSize 通知的单个订阅。 由 Observable.) 定义的 (
公共扩展方法 重试<TElement> () 已重载。 重复源可观测序列,直到成功终止。 由 Observable.) 定义的 (
公共扩展方法 重试<TElement> (Int32) 已重载。 重复源可观测序列,直到成功终止。 由 Observable.) 定义的 (
公共扩展方法 示例<TElement> (TimeSpan) 已重载。 按每个间隔对可观测序列进行采样。 由 Observable.) 定义的 (
公共扩展方法 示例<TElement> (TimeSpan、IScheduler) 已重载。 使用指定的源、间隔和计划程序对每个间隔的可观测序列采样。 由 Observable.) 定义的 (
公共扩展方法 示例<TElement、TSample> (IObservable<TSample>) 已重载。 使用指定的源和采样器在采样刻度处对可观测序列进行采样。 由 Observable.) 定义的 (
公共扩展方法 扫描<TElement> (Func<TElement、TElement、TElement>) 已重载。 对可观测序列应用累加器函数,并使用指定的源和累加器返回每个中间结果。 由 Observable.) 定义的 (
公共扩展方法 扫描<TElement、TAccumulate> (TAccumulate、Func<TAccumulate、TElement、TAccumulate>) 已重载。 对可观测序列应用累加器函数,并使用指定的源、种子和累加器返回每个中间结果。 由 Observable.) 定义的 (
公共扩展方法 依次选择 TElement<、TResult> (Func<TElement、TResult>) 已重载。 将可观测序列的每个元素投影到具有指定源和选择器的新窗体中。 由 Observable.) 定义的 (
公共扩展方法 依次选择 TElement<、TResult> (Func<TElement、Int32、TResult>) 已重载。 通过将元素的索引与指定的源和选择器合并,将可观测序列的每个元素投影到一个新窗体中。 由 Observable.) 定义的 (
公共扩展方法 SelectMany<TElement、TOther> (IObservable<TOther>) 已重载。 将可观测序列的每个元素投影到可观测序列中,并将生成的可观测序列平展为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 SelectMany<TElement、TResult> (Func<TElement、IObservable<TResult>>) 已重载。 将可观测序列的每个元素投影到可观测序列中,并将生成的可观测序列平展为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 SelectMany<TElement、TResult> (Func<TElement、IEnumerable<TResult>>) 已重载。 将可观测序列的每个元素投影到可观测序列中,并将生成的可观测序列平展为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 SelectMany<TElement、TResult> (Func<TElement、IObservable<TResult>>、Func<Exception、IObservable<TResult>>、Func<IObservable<TResult>>) 已重载。 将可观测序列的每个元素投影到可观测序列中,并将生成的可观测序列平展为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 SelectMany<TElement、TCollection、TResult> (Func<TElement、IEnumerable<TCollection>>、Func<TElement、TCollection、TResult>) 已重载。 将可观测序列的每个元素投影到可观测序列中,并将生成的可观测序列平展为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 SelectMany<TElement、TCollection、TResult> (Func<TElement、IObservable<TCollection>>、Func<TElement、TCollection、TResult>) 已重载。 将可观测序列的每个元素投影到可观测序列中,并将生成的可观测序列平展为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 SequenceEqual<TElement> (IObservable<TElement>) 已重载。 通过成对比较元素来确定两个序列是否相等。 由 Observable.) 定义的 (
公共扩展方法 SequenceEqual<TElement> (IObservable<TElement>,IEqualityComparer<TElement>) 已重载。 通过使用指定的相等比较器成对比较元素,确定两个序列是否相等。 由 Observable.) 定义的 (
公共扩展方法 单个<TElement> () 已重载。 返回可观测序列的唯一元素,如果可观测序列中没有正好有一个元素,则引发异常。 由 Observable.) 定义的 (
公共扩展方法 单个<TElement> (Func<TElement,布尔>) 已重载。 返回可观测序列中唯一与谓词匹配的元素,如果可观测序列中没有恰好一个元素,则引发异常。 由 Observable.) 定义的 (
公共扩展方法 SingleOrDefault<TElement> () 已重载。 返回可观测序列的唯一元素;如果可观察序列为空,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 SingleOrDefault<TElement> (Func<TElement,布尔>) 已重载。 返回可观测序列中与谓词匹配的唯一元素;如果未找到任何值,则返回默认值。 由 Observable.) 定义的 (
公共扩展方法 跳过<TElement> 绕过可观察序列中的指定数目的值,然后返回剩余的值。 由 Observable.) 定义的 (
公共扩展方法 SkipLast<TElement> 在可观测序列末尾绕过指定数量的元素。 由 Observable.) 定义的 (
公共扩展方法 SkipUntil<TElement、TOther> 仅当另一个可观测序列生成值后,才返回源可观测序列中的值。 由 Observable.) 定义的 (
公共扩展方法 SkipWhile<TElement> (Func<TElement,布尔>) 已重载。 只要指定的条件为 true,就绕过可观察序列中的值,然后返回剩余的值。 由 Observable.) 定义的 (
公共扩展方法 SkipWhile<TElement> (Func<TElement、Int32、布尔>) 已重载。 只要指定的条件为 true,就绕过可观察序列中的值,然后返回剩余的值。 由 Observable.) 定义的 (
公共扩展方法 StartWith<TElement>TElement[]) 已重载。 将值序列附加到具有指定源和值的可观测序列。 由 Observable.) 定义的 (
公共扩展方法 StartWith<TElement> (IScheduler, array<TElement[]) 已重载。 使用指定的源、计划程序以及值将值序列追加到可观测序列。 由 Observable.) 定义的 (
公共扩展方法 订阅<TElement> () 已重载。 计算具有指定源的可观测序列。 由 ObservableExtensions.) 定义的 (
公共扩展方法 订阅<TElement> (操作<TElement>) 已重载。 将元素处理程序订阅到可观测序列。 由 ObservableExtensions.) 定义的 (
公共扩展方法 订阅<TElement> (操作<TElement>,操作<异常>) 已重载。 将元素处理程序和异常处理程序订阅到可观测序列。 由 ObservableExtensions.) 定义的 (
公共扩展方法 订阅<TElement> (操作<TElement>、操作) 已重载。 将元素处理程序和完成处理程序订阅到可观测序列。 由 ObservableExtensions.) 定义的 (
公共扩展方法 订阅<TElement> (操作<TElement>、操作<异常>、操作) 已重载。 将元素处理程序、异常处理程序和完成处理程序订阅到可观测序列。 由 ObservableExtensions.) 定义的 (
公共扩展方法 SubscribeOn<TElement> (SynchronizationContext) 已重载。 在指定的同步上下文上异步订阅和取消订阅观察程序。 由 Observable.) 定义的 (
公共扩展方法 SubscribeOn<TElement> (控制) 已重载。 由 ControlObservable.) 定义的 (
公共扩展方法 SubscribeOn<TElement> (Dispatcher) 已重载。 由 DispatcherObservable.) 定义的 (
公共扩展方法 SubscribeOn<TElement> (DispatcherScheduler) 已重载。 由 DispatcherObservable.) 定义的 (
公共扩展方法 SubscribeOn<TElement> (IScheduler) 已重载。 异步订阅和取消订阅指定计划程序上的观察程序。 由 Observable.) 定义的 (
公共扩展方法 SubscribeOnDispatcher<TElement> DispatcherObservable.) 定义的 (
公共扩展方法 同步<TElement> () 已重载。 同步可观测序列。 由 Observable.) 定义的 (
公共扩展方法 同步<TElement> (对象) 已重载。 同步可观测序列。 由 Observable.) 定义的 (
公共扩展方法 采用<TElement> 从可观测序列的开头返回指定数量的连续值。 由 Observable.) 定义的 (
公共扩展方法 TakeLast<TElement> 从可观测序列的末尾返回指定数量的连续元素。 由 Observable.) 定义的 (
公共扩展方法 TakeUntil<TElement、TOther> 返回源可观测序列中的值,直到另一个可观测序列生成值。 由 Observable.) 定义的 (
公共扩展方法 TakeWhile<TElement> (Func<TElement,布尔) > 已重载。 只要指定的条件为 true,就从可观测序列中返回值,然后跳过其余值。 由 Observable.) 定义的 (
公共扩展方法 TakeWhile<TElement> (Func<TElement、Int32、布尔>) 已重载。 只要指定的条件为 true,就从可观测序列中返回值,然后跳过其余值。 由 Observable.) 定义的 (
公共扩展方法 然后<是 TElement、TResult> 当可观测序列具有可用值并投影值时匹配。 由 Observable.) 定义的 (
公共扩展方法 <限制 TElement> (TimeSpan) 已重载。 忽略可观测序列中的值,这些值后跟在指定源和 dueTime 的到期时间前的另一个值。 由 Observable.) 定义的 (
公共扩展方法 <限制 TElement> (TimeSpan、IScheduler) 已重载。 使用指定的源、dueTime 和计划程序,忽略可观测序列中的值,这些序列后跟另一个值。 由 Observable.) 定义的 (
公共扩展方法 TimeInterval<TElement> () 已重载。 记录具有指定源的可观测序列中连续值之间的时间间隔。 由 Observable.) 定义的 (
公共扩展方法 TimeInterval<TElement> (IScheduler) 已重载。 使用指定的源和计划程序记录可观测序列中连续值之间的时间间隔。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (TimeSpan) 已重载。 如果 dueTime 已过,则返回可观测序列或 TimeoutException。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (DateTimeOffset) 已重载。 如果 dueTime 已过,则返回可观测序列或 TimeoutException。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (TimeSpan、IObservable<TElement>) 已重载。 如果 dueTime 已过,则返回源可观测序列或其他可观测序列。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (DateTimeOffset、IObservable<TElement>) 已重载。 如果 dueTime 已过,则返回可观测序列或 TimeoutException。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (TimeSpan、IScheduler) 已重载。 如果 dueTime 已过,则返回可观测序列或 TimeoutException。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (DateTimeOffset、IScheduler) 已重载。 如果 dueTime 已过,则返回可观测序列或 TimeoutException。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (TimeSpan、IObservable<TElement>、IScheduler) 已重载。 如果 dueTime 已过,则返回源可观测序列或其他可观测序列。 由 Observable.) 定义的 (
公共扩展方法 超时<TElement> (DateTimeOffset、IObservable<TElement>、IScheduler) 已重载。 如果 dueTime 已过,则返回源可观测序列或其他可观测序列。 由 Observable.) 定义的 (
公共扩展方法 时间戳<TElement> () 已重载。 使用指定的源记录可观测序列中每个值的时间戳。 由 Observable.) 定义的 (
公共扩展方法 时间戳<TElement> (IScheduler) 已重载。 使用指定的源和计划程序记录可观测序列中每个值的时间戳。 由 Observable.) 定义的 (
公共扩展方法 ToArray<TElement> 从可观测序列创建数组。 由 Observable.) 定义的 (
公共扩展方法 ToDictionary<TElement、TKey> (Func<TElement、TKey>) 已重载。 根据指定的键选择器函数从可观测序列创建字典。 由 Observable.) 定义的 (
公共扩展方法 ToDictionary<TElement、TKey> (Func<TElement、TKey>、IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数和比较器从可观测序列创建字典。 由 Observable.) 定义的 (
公共扩展方法 ToDictionary<TElement、TKey、TElement> (Func<TElement、TKey>、Func<TElement、TElement>) 已重载。 根据指定的键选择器函数和元素选择器函数,从可观测序列创建字典。 由 Observable.) 定义的 (
公共扩展方法 ToDictionary<TElement、TKey、TElement> (Func<TElement、TKey>、Func<TElement、TElement>、IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数、比较器和元素选择器函数,从可观测序列创建字典。 由 Observable.) 定义的 (
公共扩展方法 ToEnumerable<TElement> 将可观测序列转换为可枚举序列。 由 Observable.) 定义的 (
公共扩展方法 ToEvent<TElement> 将一个可观测序列公开为具有指定源的 .NET 事件的对象。 由 Observable.) 定义的 (
公共扩展方法 ToList<TElement> 从可观测序列创建列表。 由 Observable.) 定义的 (
公共扩展方法 ToLookup<TElement、TKey> (Func<TElement、TKey>) 已重载。 根据指定的键选择器函数从可观测序列创建查找。 由 Observable.) 定义的 (
公共扩展方法 ToLookup<TElement、TKey> (Func<TElement、TKey>、IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数和比较器从可观测序列创建查找。 由 Observable.) 定义的 (
公共扩展方法 ToLookup<TElement、TKey、TElement> (Func<TElement、TKey>、Func<TElement、TElement>) 已重载。 根据指定的键选择器函数和元素选择器函数从可观测序列创建查找。 由 Observable.) 定义的 (
公共扩展方法 ToLookup<TElement、TKey、TElement> (Func<TElement、TKey>、Func<TElement、TElement>、IEqualityComparer<TKey>) 已重载。 根据指定的键选择器函数、比较器和元素选择器函数从可观测序列创建查找。 由 Observable.) 定义的 (
公共扩展方法 ToTask<TElement> () 已重载。 返回一个任务,其中包含可观测序列的最后一个值。 由 TaskObservableExtensions.) 定义的 (
公共扩展方法 ToTask<TElement> (对象) 已重载。 返回一个任务,其中包含可观测序列的最后一个值。 由 TaskObservableExtensions.) 定义的 (
公共扩展方法 ToTask<TElement> (CancellationToken) 已重载。 返回一个任务,其中包含可观测序列的最后一个值。 由 TaskObservableExtensions.) 定义的 (
公共扩展方法 ToTask<TElement> (CancellationToken、Object) 已重载。 返回一个任务,其中包含可观测序列的最后一个值。 由 TaskObservableExtensions.) 定义的 (
公共扩展方法 其中<TElement> (Func<TElement、布尔>) 已重载。 根据谓词筛选可观测序列的元素。 由 Observable.) 定义的 (
公共扩展方法 其中<TElement> (Func<TElement、Int32、布尔> 值) 已重载。 通过合并元素的索引,基于谓词筛选可观测序列的元素。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (Int32) 已重载。 将可观测序列的每个元素投影到基于元素计数信息生成的连续非重叠窗口。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (TimeSpan) 已重载。 将可观测序列的每个元素投影到基于计时信息生成的连续非重叠窗口。 由 Observable.) 定义的 (
公共扩展方法 窗口<TElement> (Int32、Int32) 已重载。 将可观测序列的每个元素投影到零个或多个窗口,这些窗口基于元素计数信息生成。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (TimeSpan、IScheduler) 已重载。 将可观测序列的每个元素投影到基于计时信息生成的连续非重叠窗口。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (TimeSpan、TimeSpan) 已重载。 将可观测序列的每个元素投影到基于计时信息生成的零个或多个窗口。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (TimeSpan,Int32) 已重载。 将可观测序列的每个元素投影到一个窗口,该窗口在已满或经过给定时间时完成。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (TimeSpan、TimeSpan、IScheduler) 已重载。 将可观测序列的每个元素投影到基于计时信息生成的零个或多个窗口。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement> (TimeSpan、Int32、IScheduler) 已重载。 将可观测序列的每个元素投影到一个窗口,该窗口在已满或经过给定时间时完成。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement、TWindowClosing> (Func<IObservable<TWindowClosing>>) 已重载。 将可观测序列的每个元素投影到连续的非重叠窗口。 由 Observable.) 定义的 (
公共扩展方法 Window<TElement、TWindowOpening、TWindowClosing> (IObservable<TWindowOpening>、Func<TWindowOpening、IObservable<TWindowClosing>>) 已重载。 将可观测序列的每个元素投影到零个或多个窗口中。 由 Observable.) 定义的 (
公共扩展方法 Zip<TElement、TSecond、TResult> (IObservable<TSecond>、Func<TElement、TSecond、TResult>) 已重载。 通过将两个可观测序列以成对方式组合其元素,将两个可观测序列合并为一个可观测序列。 由 Observable.) 定义的 (
公共扩展方法 Zip<TElement、TSecond、TResult> (IEnumerable<TSecond>、Func<TElement、TSecond、TResult>) 已重载。 使用选择器函数将可观测序列和可枚举序列合并到一个可观测序列中。 由 Observable.) 定义的 (

顶部

另请参阅

参考

System.Reactive.Linq 命名空间