Qbservable.Replay<TSource、TResult> 方法 (IQbservable<TSource>、Expression<Func<IObservable<TSource>、IObservable<TResult>>>、Int32、TimeSpan、IScheduler)

返回一个可查询可观测序列，该序列是调用可连接可查询可观测序列上的选择器的结果，该序列共享对窗口中的基础序列重播 bufferSize 通知的单个订阅。

Namespace：System.Reactive.Linq
装配： system.Reactive.Providers 在 System.Reactive.Providers.dll) 中 (

语法

'Declaration
<ExtensionAttribute> _
Public Shared Function Replay(Of TSource, TResult) ( _
    source As IQbservable(Of TSource), _
    selector As Expression(Of Func(Of IObservable(Of TSource), IObservable(Of TResult))), _
    bufferSize As Integer, _
    window As TimeSpan, _
    scheduler As IScheduler _
) As IQbservable(Of TResult)

'Usage
Dim source As IQbservable(Of TSource)
Dim selector As Expression(Of Func(Of IObservable(Of TSource), IObservable(Of TResult)))
Dim bufferSize As Integer
Dim window As TimeSpan
Dim scheduler As IScheduler
Dim returnValue As IQbservable(Of TResult)

returnValue = source.Replay(selector, _
    bufferSize, window, scheduler)

public static IQbservable<TResult> Replay<TSource, TResult>(
    this IQbservable<TSource> source,
    Expression<Func<IObservable<TSource>, IObservable<TResult>>> selector,
    int bufferSize,
    TimeSpan window,
    IScheduler scheduler
)

[ExtensionAttribute]
public:
generic<typename TSource, typename TResult>
static IQbservable<TResult>^ Replay(
    IQbservable<TSource>^ source, 
    Expression<Func<IObservable<TSource>^, IObservable<TResult>^>^>^ selector, 
    int bufferSize, 
    TimeSpan window, 
    IScheduler^ scheduler
)

static member Replay : 
        source:IQbservable<'TSource> * 
        selector:Expression<Func<IObservable<'TSource>, IObservable<'TResult>>> * 
        bufferSize:int * 
        window:TimeSpan * 
        scheduler:IScheduler -> IQbservable<'TResult> 

JScript does not support generic types and methods.

类型参数

• TSource
  源的类型。

• TResult
  结果的类型。

参数

• source
  类型： System.Reactive.Linq.IQbservable<TSource>
  其元素将通过单个共享订阅进行多播的源序列。

• 选择器
  类型： System.Linq.Expressions.Expression<Func<IObservable<TSource>、 IObservable<TResult>>>
  选择器函数，它可以根据需要多次使用多播源序列，而不会导致源序列的多个订阅。

• bufferSize
  类型： System.Int32
  重播缓冲区的最大元素计数。

• window
  类型： System.TimeSpan
  重播缓冲区的最大时间长度。

• scheduler
  类型： System.Reactive.Concurrency.IScheduler
  将在其上调用选择器函数内连接的观察器的计划程序。

返回值

类型： System.Reactive.Linq.IQbservable<TResult>
一个可查询的可观察序列，包含通过在选择器函数内多播源序列生成的序列的元素。

使用说明

在 Visual Basic 和 C# 中，可以在 IQbservable<TSource> 类型的任何对象上调用此方法作为实例方法。 当使用实例方法语法调用此方法时，请省略第一个参数。 有关详细信息，请参阅或。

另请参阅

参考

Qbservable 类

重播重载

System.Reactive.Linq 命名空间