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