Metodo Qbservable.Merge<TSource> (IQbservableProvider, IEnumerable IObservable<<TSource>>, Int32, IScheduler)

Unisce una sequenza enumerabile di sequenze osservabili su cui è possibile eseguire query in una sequenza osservabile querybile, limitando il numero di sottoscrizioni simultanee alle sequenze interne.

Spazio dei nomi:System.Reactive.Linq
Assemblea: System.Reactive.Providers (in System.Reactive.Providers.dll)

Sintassi

'Declaration
<ExtensionAttribute> _
Public Shared Function Merge(Of TSource) ( _
    provider As IQbservableProvider, _
    sources As IEnumerable(Of IObservable(Of TSource)), _
    maxConcurrent As Integer, _
    scheduler As IScheduler _
) As IQbservable(Of TSource)

'Usage
Dim provider As IQbservableProvider
Dim sources As IEnumerable(Of IObservable(Of TSource))
Dim maxConcurrent As Integer
Dim scheduler As IScheduler
Dim returnValue As IQbservable(Of TSource)

returnValue = provider.Merge(sources, _
    maxConcurrent, scheduler)

public static IQbservable<TSource> Merge<TSource>(
    this IQbservableProvider provider,
    IEnumerable<IObservable<TSource>> sources,
    int maxConcurrent,
    IScheduler scheduler
)

[ExtensionAttribute]
public:
generic<typename TSource>
static IQbservable<TSource>^ Merge(
    IQbservableProvider^ provider, 
    IEnumerable<IObservable<TSource>^>^ sources, 
    int maxConcurrent, 
    IScheduler^ scheduler
)

static member Merge : 
        provider:IQbservableProvider * 
        sources:IEnumerable<IObservable<'TSource>> * 
        maxConcurrent:int * 
        scheduler:IScheduler -> IQbservable<'TSource> 

JScript does not support generic types and methods.

Parametri di tipo

• TSource
  Tipo di origine.

Parametri

• provider
  Tipo: System.Reactive.Linq.IQbservableProvider
  Provider Qbservable locale.

• sources
  Tipo: System.Collections.Generic.IEnumerableIObservable<< TSource>>
  Sequenza enumerabile di sequenze osservabili su cui è possibile eseguire query.

• maxConcurrent
  Tipo: System.Int32
  Numero massimo di sequenze osservabili eseguibili da query sottoscritte contemporaneamente.

• scheduler
  Tipo: System.Reactive.Concurrency.IScheduler
  Utilità di pianificazione in cui eseguire l'enumerazione della sequenza di origini.

Valore restituito

Tipo: System.Reactive.Linq.IQbservable<TSource>
Sequenza osservabile su cui è possibile eseguire query che unisce gli elementi delle sequenze osservabili eseguibili da query.

Nota sull'utilizzo

In Visual Basic e C# è possibile chiamare questo metodo come metodo di istanza su qualsiasi oggetto di tipo IQbservableProvider. Per chiamare il metodo usando la sintassi del metodo di istanza, omettere il primo parametro. Per altre informazioni, vedere o .

Vedere anche

Riferimento

Classe Qbservable

Merge Overload

Spazio dei nomi System.Reactive.Linq