Observable.Replay<TSource, TResult> Method (IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan, IScheduler)
Возвращает наблюдаемую последовательность, которая является результатом вызова селектора для подключаемой наблюдаемой последовательности, которая использует одну подписку для базовой последовательности, которая выполняет повторение bufferSize-уведомлений в окне.
Пространство имен:System.Reactive.Linq
Сборки: System.Reactive (в System.Reactive.dll)
Синтаксис
'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>
Исходная последовательность, элементы которой будут многоадресной рассылкой через одну общую подписку.
- selector
Тип: 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>. При вызове метода для экземпляра следует опускать первый параметр. Дополнительные сведения см. в разделе или .