Qbservable.Replay<TSource, méthode TResult> (IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, Int32, TimeSpan, IScheduler)
Retourne une séquence observable interrogeable qui est le résultat de l’appel du sélecteur sur une séquence observable interrogeable connectable qui partage un abonnement unique aux notifications bufferSize de séquence sous-jacentes dans la fenêtre.
Namespace:System.Reactive.Linq
Assemblée: System.Reactive.Providers (en System.Reactive.Providers.dll)
Syntaxe
'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.
Paramètres de type
- TSource
Type de la source.
- TResult
Type de résultat.
Paramètres
- source
Type : System.Reactive.Linq.IQbservable<TSource>
Séquence source dont les éléments seront en multidiffusion via un seul abonnement partagé.
- selector
Type : System.Linq.Expressions.Expression<Func<IObservable<TSource>, IObservable<TResult>>>
Fonction de sélecteur qui peut utiliser la séquence source multidiffusion autant de fois que nécessaire, sans provoquer plusieurs abonnements à la séquence source.
- bufferSize
Type : System.Int32
Nombre maximal d’éléments de la mémoire tampon de relecture.
- window
Type : System.TimeSpan
Durée maximale de la mémoire tampon de relecture.
- scheduler
Type : System.Reactive.Concurrency.IScheduler
Planificateur sur lequel les observateurs connectés dans la fonction de sélecteur seront appelés.
Valeur de retour
Type : System.Reactive.Linq.IQbservable<TResult>
Séquence observable interrogeable qui contient les éléments d’une séquence produite par la multidiffusion de la séquence source dans une fonction de sélecteur.
Remarque sur l'utilisation
Dans Visual Basic et C#, vous pouvez appeler cette méthode en tant que méthode instance sur n’importe quel objet de type IQbservable<TSource>. Lorsque vous utilisez la syntaxe des méthodes d'instance pour appeler cette méthode, omettez le premier paramètre. Pour plus d'informations, consultez ou .