[])} })} ,System.IObservable{--1},System.Linq.Expressions.Expression{System.Func{--0,--1,--2}})}

QbservableEx.ForkJoin(IQbservableProvider, IObservable[]) method¶

Defined in

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

Applies to

netstandard2.0

Overloads¶

1. public static IQbservable<TSource[]> ForkJoin<TSource>(this IQbservableProvider provider, params IObservable<TSource>[] sources)
2. public static IQbservable<TSource[]> ForkJoin<TSource>(this IQbservableProvider provider, IEnumerable<IObservable<TSource>> sources)
3. public static IQbservable<TResult> ForkJoin<TSource1, TSource2, TResult>(this IQbservable<TSource1> first, IObservable<TSource2> second, Expression<Func<TSource1, TSource2, TResult>> resultSelector)

1. Overload¶

Attributes: [Experimental]

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

Summary: Runs all specified observable sequences in parallel and collects their last elements.

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 sequence to collect the last elements for.

Returns: [IQbservable][T:System.Reactive.Linq.IQbservable-1] -- An observable sequence with an array collecting the last elements of all the input sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.

2. Overload¶

Attributes: [Experimental]

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

Summary: Runs all observable sequences in the enumerable sources sequence in parallel and collect their last elements.

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>	Observable sequence to collect the last elements for.

Returns: [IQbservable][T:System.Reactive.Linq.IQbservable-1] -- An observable sequence with an array collecting the last elements of all the input sequences.

Exceptions

Type	Condition
System.ArgumentNullException	`sources` is null.

3. Overload¶

Attributes: [Experimental]

public static IQbservable<TResult> ForkJoin<TSource1, TSource2, TResult>(this IQbservable<TSource1> first, IObservable<TSource2> second, Expression<Func<TSource1, TSource2, TResult>> resultSelector)

Summary: Runs two observable sequences in parallel and combines their last elements.

Type parameters

Name	Description
`TSource1`	The type of the elements in the first source sequence.
`TSource2`	The type of the elements in the second source sequence.
`TResult`	The type of the elements in the result sequence, returned by the selector function.

Parameters

Name	Type	Description
`first`	[IQbservable](#	First observable sequence.
`second`	IObservable	Second observable sequence.
`resultSelector`	Expression>	Result selector function to invoke with the last elements of both sequences.

Returns: IQbservable -- An observable sequence with the result of calling the selector function with the last elements of both input sequences.

Exceptions

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