Qbservable.Replay<TSource, metoda TResult> (IQbservable TSource, Expression<Func<IObservable<TSource>>, IObservable<<TResult>>>, Int32, TimeSpan, IScheduler)
Zwraca możliwą do obserwacji sekwencję, która jest wynikiem wywołania selektora w możliwej do obserwowalnej sekwencji, która udostępnia jedną subskrypcję bazowej sekwencji reping bufferSize powiadomień w oknie.
Przestrzeń nazw:System.Reactive.Linq
Zestawu: System.Reactive.Providers (w System.Reactive.Providers.dll)
Składnia
'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.
Parametry typu
- Tsource
Typ źródła.
- Tresult
Typ wyniku.
Parametry
- source
Typ: System.Reactive.Linq.IQbservable<TSource>
Sekwencja źródłowa, której elementy będą multiemisji za pośrednictwem pojedynczej udostępnionej subskrypcji.
- selector (selektor)
Typ: System.Linq.Expressions.Expression<Func<IObservable<TSource>, IObservable<TResult>>>
Funkcja selektora, która może używać wieloemisji sekwencji źródłowej tyle razy, ile to konieczne, bez powodowania wielu subskrypcji do sekwencji źródłowej.
- bufferSize
Typ: System.Int32
Maksymalna liczba elementów buforu odtwarzania.
- okno
Typ: System.TimeSpan
Maksymalny czas buforu odtwarzania.
- scheduler
Typ: System.Reactive.Concurrency.IScheduler
Harmonogram, w którym będą wywoływani połączeni obserwatorzy w funkcji selektora.
Wartość zwracana
Typ: System.Reactive.Linq.IQbservable<TResult>
Możliwa do obserwacji sekwencja, która zawiera elementy sekwencji utworzonej przez multiemisję sekwencji źródłowej w funkcji selektora.
Uwaga dotycząca użycia
W języku Visual Basic i C#można wywołać tę metodę jako metodę wystąpienia w dowolnym obiekcie typu IQbservable<TSource>. Gdy w celu wywołania tej metody jest używana składnia metody wystąpienia, należy pominąć pierwszy parametr. Aby uzyskać więcej informacji, zobacz lub .