返回一个可观察序列,该序列是在可连接的可观测序列上调用选择器的结果,该序列共享对窗口内的基础序列重播 bufferSize 通知的单个订阅。
Namespace:System.Reactive.Linq
装配: System.Reactive.dll) 中的 System.Reactive (
语法
'Declaration
<ExtensionAttribute> _
Public Shared Function Replay(Of TSource, TResult) ( _
source As IObservable(Of TSource), _
selector As Func(Of IObservable(Of TSource), IObservable(Of TResult)), _
bufferSize As Integer, _
window As TimeSpan, _
scheduler As IScheduler _
) As IObservable(Of TResult)
'Usage
Dim source As IObservable(Of TSource)
Dim selector As Func(Of IObservable(Of TSource), IObservable(Of TResult))
Dim bufferSize As Integer
Dim window As TimeSpan
Dim scheduler As IScheduler
Dim returnValue As IObservable(Of TResult)
returnValue = source.Replay(selector, _
bufferSize, window, scheduler)
public static IObservable<TResult> Replay<TSource, TResult>(
this IObservable<TSource> source,
Func<IObservable<TSource>, IObservable<TResult>> selector,
int bufferSize,
TimeSpan window,
IScheduler scheduler
)
[ExtensionAttribute]
public:
generic<typename TSource, typename TResult>
static IObservable<TResult>^ Replay(
IObservable<TSource>^ source,
Func<IObservable<TSource>^, IObservable<TResult>^>^ selector,
int bufferSize,
TimeSpan window,
IScheduler^ scheduler
)
static member Replay :
source:IObservable<'TSource> *
selector:Func<IObservable<'TSource>, IObservable<'TResult>> *
bufferSize:int *
window:TimeSpan *
scheduler:IScheduler -> IObservable<'TResult>
JScript does not support generic types and methods.
类型参数
- TSource
源的类型。
- TResult
结果的类型。
参数
- source
类型: System.IObservable<TSource>
其元素将通过单个共享订阅进行多播的源序列。
- 选择器
类型: System.Func<IObservable<TSource>、 IObservable<TResult>>
选择器函数,它可以根据需要多次使用多播源序列,而不会导致对源序列进行多个订阅。
- bufferSize
类型: System.Int32
重播缓冲区的最大元素计数。
- window
类型: System.TimeSpan
重播缓冲区的最大时间长度。
- scheduler
类型: System.Reactive.Concurrency.IScheduler
将在其中调用选择器函数中的连接观察程序的计划程序。
返回值
类型: System.IObservable<TResult>
一个可观测序列,其中包含通过在选择器函数中多播源序列生成的序列的元素。
使用说明
在 Visual Basic 和 C# 中,可以将此方法作为 IObservable<TSource> 类型的任何对象的实例方法调用。 当使用实例方法语法调用此方法时,请省略第一个参数。 有关详细信息,请参阅或。