Udostępnij za pośrednictwem


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

Scala wyliczaną sekwencję obserwowanych sekwencji w sekwencji możliwej do obserwacji, ograniczając liczbę równoczesnych subskrypcji do sekwencji wewnętrznych.

Przestrzeń nazw:System.Reactive.Linq
Zestawu: System.Reaktywny (w System.Reactive.dll)

Składnia

'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.

Parametry typu

  • Tsource
    Typ źródła.

Parametry

  • maxConcurrent
    Typ: System.Int32
    Maksymalna liczba obserwowanych sekwencji subskrybowanych współbieżnie.

Wartość zwracana

Typ: System.IObservable<TSource>
Obserwowana sekwencja, która scala elementy obserwowanych sekwencji.

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 IEnumerable IObservable<<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 .

Zobacz też

Odwołanie

Obserwowana klasa

Przeciążenie scalania

Przestrzeń nazw System.Reactive.Linq