,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

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)

Summary: Merges elements from two observable sequences into a single observable sequence.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`first`	[IQbservable](#	First observable sequence.
`second`	IObservable	Second observable sequence.

Returns: IQbservable -- The observable sequence that merges the elements of the given sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`first` or `second` is null.

2. Overload¶

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

Summary: Merges elements from two observable sequences into a single observable sequence, using the specified scheduler for enumeration of and subscription to the sources.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`first`	[IQbservable](#	First observable sequence.
`second`	IObservable	Second observable sequence.
`scheduler`	[IScheduler](#	Scheduler used to introduce concurrency for making subscriptions to the given sequences.

Returns: IQbservable -- The observable sequence that merges the elements of the given sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`first` or `second` or `scheduler` is null.

3. Overload¶

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

Summary: Merges elements from all of the specified observable sequences into a single observable sequence, using the specified scheduler for enumeration of and subscription to the sources.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`provider`	[IQbservableProvider](#	Query provider used to construct the [IQbservable](# data source.
`scheduler`	[IScheduler](#	Scheduler to run the enumeration of the sequence of sources on.
`params sources`	`IObservable<TSource>[]`	Observable sequences.

Returns: IQbservable -- The observable sequence that merges the elements of the observable sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`scheduler` or `sources` is null.

4. Overload¶

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

Summary: Merges elements from all inner observable sequences into a single observable sequence.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`sources`	[IQbservable>](#	Observable sequence of inner observable sequences.

Returns: IQbservable -- The observable sequence that merges the elements of the inner sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.

5. Overload¶

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

Summary: Merges results from all source tasks into a single observable sequence.

Type parameters

Name	Description
`TSource`	The type of the results produced by the source tasks.

Parameters

Name	Type	Description
`sources`	[IQbservable>](#	Observable sequence of tasks.

Returns: IQbservable -- The observable sequence that merges the results of the source tasks.

Remarks

If the tasks support cancellation, consider manual conversion of the tasks using FromAsync, followed by a merge operation using Merge.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.

6. Overload¶

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

Summary: Merges elements from all of the specified observable sequences into a single observable sequence.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`provider`	[IQbservableProvider](#	Query provider used to construct the [IQbservable](# data source.
`params sources`	`IObservable<TSource>[]`	Observable sequences.

Returns: IQbservable -- The observable sequence that merges the elements of the observable sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.

7. Overload¶

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

Summary: Merges elements from all observable sequences in the given enumerable sequence into a single observable sequence.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`provider`	[IQbservableProvider](#	Query provider used to construct the [IQbservable](# data source.
`sources`	IEnumerable>	Enumerable sequence of observable sequences.

Returns: IQbservable -- The observable sequence that merges the elements of the observable sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.

8. Overload¶

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

Summary: Merges elements from all inner observable sequences into a single observable sequence, limiting the number of concurrent subscriptions to inner sequences.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`sources`	[IQbservable>](#	Observable sequence of inner observable sequences.
`maxConcurrent`	int	Maximum number of inner observable sequences being subscribed to concurrently.

Returns: IQbservable -- The observable sequence that merges the elements of the inner sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.
System.ArgumentOutOfRangeException	`maxConcurrent` is less than or equal to zero.

9. Overload¶

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

Summary: Merges elements from all observable sequences in the given enumerable sequence into a single observable sequence, limiting the number of concurrent subscriptions to inner sequences.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`provider`	[IQbservableProvider](#	Query provider used to construct the [IQbservable](# data source.
`sources`	IEnumerable>	Enumerable sequence of observable sequences.
`maxConcurrent`	int	Maximum number of observable sequences being subscribed to concurrently.

Returns: IQbservable -- The observable sequence that merges the elements of the observable sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.
System.ArgumentOutOfRangeException	`maxConcurrent` is less than or equal to zero.

10. Overload¶

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

Summary: Merges elements from all observable sequences in the given enumerable sequence into a single observable sequence, limiting the number of concurrent subscriptions to inner sequences, and using the specified scheduler for enumeration of and subscription to the sources.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`provider`	[IQbservableProvider](#	Query provider used to construct the [IQbservable](# data source.
`sources`	IEnumerable>	Enumerable sequence of observable sequences.
`maxConcurrent`	int	Maximum number of observable sequences being subscribed to concurrently.
`scheduler`	[IScheduler](#	Scheduler to run the enumeration of the sequence of sources on.

Returns: IQbservable -- The observable sequence that merges the elements of the observable sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` or `scheduler` is null.
System.ArgumentOutOfRangeException	`maxConcurrent` is less than or equal to zero.

11. Overload¶

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

Summary: Merges elements from all observable sequences in the given enumerable sequence into a single observable sequence, using the specified scheduler for enumeration of and subscription to the sources.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequences.

Parameters

Name	Type	Description
`provider`	[IQbservableProvider](#	Query provider used to construct the [IQbservable](# data source.
`sources`	IEnumerable>	Enumerable sequence of observable sequences.
`scheduler`	[IScheduler](#	Scheduler to run the enumeration of the sequence of sources on.

Returns: IQbservable -- The observable sequence that merges the elements of the observable sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` or `scheduler` is null.