Skip to content

,System.IObservable{--0})} ,System.IObservable{--0},System.Reactive.Concurrency.IScheduler)} [])} })} })} [])} })} },System.Int32)} },System.Int32)} },System.Int32,System.Reactive.Concurrency.IScheduler)} },System.Reactive.Concurrency.IScheduler)}

Qbservable.Merge(IQbservable, IObservable) method

Defined in

Type: Qbservable Namespace: System.Reactive.Linq Assembly: System.Reactive.dll

Applies to

net8.0, net8.0-windows10.0.19041, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.0

Overloads

  • 1. public static IQbservable<TSource> Merge<TSource>(this IQbservable<TSource> first, IObservable<TSource> second)
  • 2. public static IQbservable<TSource> Merge<TSource>(this IQbservable<TSource> first, IObservable<TSource> second, IScheduler scheduler)
  • 3. public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, IScheduler scheduler, params IObservable<TSource>[] sources)
  • 4. public static IQbservable<TSource> Merge<TSource>(this IQbservable<IObservable<TSource>> sources)
  • 5. public static IQbservable<TSource> Merge<TSource>(this IQbservable<Task<TSource>> sources)
  • 6. public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, params IObservable<TSource>[] sources)
  • 7. public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, IEnumerable<IObservable<TSource>> sources)
  • 8. public static IQbservable<TSource> Merge<TSource>(this IQbservable<IObservable<TSource>> sources, int maxConcurrent)
  • 9. public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, IEnumerable<IObservable<TSource>> sources, int maxConcurrent)
  • 10. public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, IEnumerable<IObservable<TSource>> sources, int maxConcurrent, IScheduler scheduler)
  • 11. public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, IEnumerable<IObservable<TSource>> sources, IScheduler scheduler)

1. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservable<TSource> first, IObservable<TSource> second)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
first[IQbservable](#--
secondIObservable--

Returns: IQbservable

2. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservable<TSource> first, IObservable<TSource> second, IScheduler scheduler)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
first[IQbservable](#--
secondIObservable--
scheduler[IScheduler](#--

Returns: IQbservable

3. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, IScheduler scheduler, params IObservable<TSource>[] sources)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
provider[IQbservableProvider](#--
scheduler[IScheduler](#--
params sourcesIObservable<TSource>[]--

Returns: IQbservable

4. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservable<IObservable<TSource>> sources)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sources[IQbservable>](#--

Returns: IQbservable

5. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservable<Task<TSource>> sources)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sources[IQbservable>](#--

Returns: IQbservable

6. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservableProvider provider, params IObservable<TSource>[] sources)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
provider[IQbservableProvider](#--
params sourcesIObservable<TSource>[]--

Returns: IQbservable

7. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
provider[IQbservableProvider](#--
sourcesIEnumerable>--

Returns: IQbservable

8. Overload

public static IQbservable<TSource> Merge<TSource>(this IQbservable<IObservable<TSource>> sources, int maxConcurrent)

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
sources[IQbservable>](#--
maxConcurrentint--

Returns: IQbservable

9. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
provider[IQbservableProvider](#--
sourcesIEnumerable>--
maxConcurrentint--

Returns: IQbservable

10. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
provider[IQbservableProvider](#--
sourcesIEnumerable>--
maxConcurrentint--
scheduler[IScheduler](#--

Returns: IQbservable

11. Overload

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

Type parameters

NameDescription
TSource--

Parameters

NameTypeDescription
provider[IQbservableProvider](#--
sourcesIEnumerable>--
scheduler[IScheduler](#--

Returns: IQbservable