Udostępnij za pośrednictwem


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

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 _
) As IObservable(Of TSource)
'Usage
Dim sources As IEnumerable(Of IObservable(Of TSource))
Dim maxConcurrent As Integer
Dim returnValue As IObservable(Of TSource)

returnValue = sources.Merge(maxConcurrent)
public static IObservable<TSource> Merge<TSource>(
    this IEnumerable<IObservable<TSource>> sources,
    int maxConcurrent
)
[ExtensionAttribute]
public:
generic<typename TSource>
static IObservable<TSource>^ Merge(
    IEnumerable<IObservable<TSource>^>^ sources, 
    int maxConcurrent
)
static member Merge : 
        sources:IEnumerable<IObservable<'TSource>> * 
        maxConcurrent:int -> 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