Freigeben über


Observable.Merge<TSource-Methode> (IEnumerable<IObservable<TSource>>, Int32, IScheduler)

Führt eine aufzählbare Sequenz beobachtbarer Sequenzen zu einer beobachtbaren Sequenz zusammen, wodurch die Anzahl gleichzeitiger Abonnements auf innere Sequenzen beschränkt wird.

Namespace:System.Reactive.Linq
Versammlung: System.Reactive (in System.Reactive.dll)

Syntax

'Declaration
<ExtensionAttribute> _
Public Shared Function Merge(Of TSource) ( _
    sources As IEnumerable(Of IObservable(Of TSource)), _
    maxConcurrent As Integer, _
    scheduler As IScheduler _
) As IObservable(Of TSource)
'Usage
Dim sources As IEnumerable(Of IObservable(Of TSource))
Dim maxConcurrent As Integer
Dim scheduler As IScheduler
Dim returnValue As IObservable(Of TSource)

returnValue = sources.Merge(maxConcurrent, _
    scheduler)
public static IObservable<TSource> Merge<TSource>(
    this IEnumerable<IObservable<TSource>> sources,
    int maxConcurrent,
    IScheduler scheduler
)
[ExtensionAttribute]
public:
generic<typename TSource>
static IObservable<TSource>^ Merge(
    IEnumerable<IObservable<TSource>^>^ sources, 
    int maxConcurrent, 
    IScheduler^ scheduler
)
static member Merge : 
        sources:IEnumerable<IObservable<'TSource>> * 
        maxConcurrent:int * 
        scheduler:IScheduler -> IObservable<'TSource> 
JScript does not support generic types and methods.

Typparameter

  • TSource
    Der Quellentyp.

Parameter

  • maxConcurrent
    Typ: System.Int32
    Die maximale Anzahl von beobachtbaren Sequenzen, die gleichzeitig abonniert werden.

Rückgabewert

Typ: System.IObservable<TSource>
Die beobachtbare Sequenz, die die Elemente der beobachtbaren Sequenzen zusammenführt.

Hinweis zur Verwendung

In Visual Basic und C# können Sie diese Methode als instance-Methode für jedes Objekt vom Typ IEnumerable<IObservable<TSource>> aufrufen. Bei Verwendung der Syntax für Instanzenmethoden lassen Sie den ersten Parameter aus. Weitere Informationen finden Sie unter oder .

Weitere Informationen

Verweis

Observable-Klasse

Mergeüberladung

System.Reactive.Linq-Namespace