Class Subscribable

Provides a set of query operators for subscribable sequences.

Inheritance

System.Object

Subscribable

Namespace: Reaqtive

Assembly: Reaqtive.Linq.dll

Syntax

public static class Subscribable : Object

Methods

Aggregate<TSource>(ISubscribable<TSource>, Func<TSource, TSource, TSource>)

Aggregates the elements in the source sequence using the specified aggregation function.

Declaration

public static ISubscribable<TSource> Aggregate<TSource>(this ISubscribable<TSource> source, Func<TSource, TSource, TSource> aggregate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to aggregate.
System.Func<TSource, TSource, TSource>	aggregate	Aggregation function used to combine the running aggregation result with each consecutive element.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing a single element representing the result of the aggregation. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Aggregate<TSource, TResult>(ISubscribable<TSource>, TResult, Func<TResult, TSource, TResult>)

Aggregates the elements in the source sequence starting from an initial seed value and using the specified aggregation function.

Declaration

public static ISubscribable<TResult> Aggregate<TSource, TResult>(this ISubscribable<TSource> source, TResult seed, Func<TResult, TSource, TResult> accumulate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to aggregate.
TResult	seed	Seed value of the aggregation.
System.Func<TResult, TSource, TResult>	accumulate	Aggregation function used to combine the running aggregation result with each consecutive element.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing a single element representing the result of the aggregation.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TResult	Type of the result of the aggregation.

Aggregate<TSource, TAccumulate, TResult>(ISubscribable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>)

Aggregates the elements in the source sequence starting from an initial seed value, using the specified aggregation function, and using a selector function to project the result.

Declaration

public static ISubscribable<TResult> Aggregate<TSource, TAccumulate, TResult>(this ISubscribable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulate, Func<TAccumulate, TResult> resultSelector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to aggregate.
TAccumulate	seed	Seed value of the aggregation.
System.Func<TAccumulate, TSource, TAccumulate>	accumulate	Aggregation function used to combine the running aggregation result with each consecutive element.
System.Func<TAccumulate, TResult>	resultSelector	Selector function to apply to the resulting intermediate aggregation value.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing a single element representing the result of the aggregation.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TAccumulate	Type of the intermediate aggregation values.
TResult	Type of the result of the aggregation.

All<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Aggregates the source sequence to determine whether all of the elements match the specified predicate.

Declaration

public static ISubscribable<bool> All<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to match with the predicate.
System.Func<TSource, System.Boolean>	predicate	Predicate function to apply to each element of the source sequence. Upon encountering the first element that doesn't pass the predicate, the aggregation operation will stop.

Returns

Type	Description
ISubscribable<System.Boolean>	Observable sequence containing a single element with value true if all elements in the source sequence match the predicate; otherwise a single element with value false. If the source sequence is empty, an element with value true is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Any<TSource>(ISubscribable<TSource>)

Aggregates the source sequence to determine whether it contains any element.

Declaration

public static ISubscribable<bool> Any<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to check for the presence of elements.

Returns

Type	Description
ISubscribable<System.Boolean>	Observable sequence containing a single element with value true if the source sequence is not empty; otherwise a single element with value false.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Any<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Aggregates the source sequence to determine whether any of the elements matches the specified predicate.

Declaration

public static ISubscribable<bool> Any<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to match with the predicate.
System.Func<TSource, System.Boolean>	predicate	Predicate function to apply to each element of the source sequence. Upon encountering the first element that does pass the predicate, the aggregation operation will stop.

Returns

Type	Description
ISubscribable<System.Boolean>	Observable sequence containing a single element with value true if any element in the source sequence matches the predicate; otherwise a single element with value false. If the source sequence is empty, an element with value false is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average(ISubscribable<Decimal>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<Decimal> Average(this ISubscribable<Decimal> source)

Parameters

Type	Name	Description
ISubscribable<System.Decimal>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Average(ISubscribable<Double>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<double> Average(this ISubscribable<double> source)

Parameters

Type	Name	Description
ISubscribable<System.Double>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Average(ISubscribable<Int32>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<double> Average(this ISubscribable<int> source)

Parameters

Type	Name	Description
ISubscribable<System.Int32>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Average(ISubscribable<Int64>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<double> Average(this ISubscribable<long> source)

Parameters

Type	Name	Description
ISubscribable<System.Int64>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Average(ISubscribable<Nullable<Decimal>>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<Nullable<Decimal>> Average(this ISubscribable<Nullable<Decimal>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Decimal>>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, a null value is returned.

Average(ISubscribable<Nullable<Double>>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<Nullable<double>> Average(this ISubscribable<Nullable<double>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Double>>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, a null value is returned.

Average(ISubscribable<Nullable<Int32>>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<Nullable<double>> Average(this ISubscribable<Nullable<int>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int32>>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, a null value is returned.

Average(ISubscribable<Nullable<Int64>>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<Nullable<double>> Average(this ISubscribable<Nullable<long>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int64>>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, a null value is returned.

Average(ISubscribable<Nullable<Single>>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<Nullable<float>> Average(this ISubscribable<Nullable<float>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Single>>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, a null value is returned.

Average(ISubscribable<Single>)

Aggregates the source sequence to return the average of the element values.

Declaration

public static ISubscribable<float> Average(this ISubscribable<float> source)

Parameters

Type	Name	Description
ISubscribable<System.Single>	source	Source sequence whose average of elements to obtain.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the average of all values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Decimal> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, Decimal> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Decimal>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Double>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<double> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, double> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Double>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<double> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, int> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Int32>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<double> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, long> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Int64>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<Decimal>> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<Decimal>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Decimal>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<double>> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<double>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Double>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<double>> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<int>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int32>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<double>> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<long>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int64>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<float>> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<float>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Single>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Average<TSource>(ISubscribable<TSource>, Func<TSource, Single>)

Aggregates the source sequence to return the average of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<float> Average<TSource>(this ISubscribable<TSource> source, Func<TSource, float> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose average of projected elements to obtain.
System.Func<TSource, System.Single>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the average of all projected values in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Buffer<TSource>(ISubscribable<TSource>, Int32)

Partitions the source sequence into buffers based on the specified buffer length.

Declaration

public static ISubscribable<IList<TSource>> Buffer<TSource>(this ISubscribable<TSource> source, int count)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate buffers for.
System.Int32	count	Number of elements per buffer.

Returns

Type	Description
ISubscribable<System.Collections.Generic.IList<TSource>>	Observable sequence containing buffers of the specified length over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Buffer<TSource>(ISubscribable<TSource>, Int32, Int32)

Partitions the source sequence into buffers based on the specified buffer length and element skip count.

Declaration

public static ISubscribable<IList<TSource>> Buffer<TSource>(this ISubscribable<TSource> source, int count, int skip)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate buffers for.
System.Int32	count	Number of elements per buffer.
System.Int32	skip	Offset of the number of elements between the start of one buffer and the next.

Returns

Type	Description
ISubscribable<System.Collections.Generic.IList<TSource>>	Observable sequence containing buffers of the specified length over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Buffer<TSource>(ISubscribable<TSource>, TimeSpan)

Partitions the source sequence into buffers based on the specified buffer duration.

Declaration

public static ISubscribable<IList<TSource>> Buffer<TSource>(this ISubscribable<TSource> source, TimeSpan duration)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate buffers for.
System.TimeSpan	duration	Duration of a buffer.

Returns

Type	Description
ISubscribable<System.Collections.Generic.IList<TSource>>	Observable sequence containing buffers of the specified duration over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Buffer<TSource>(ISubscribable<TSource>, TimeSpan, Int32)

Partitions the source sequence into buffers that are sent out when they're full or a given amount of time has elapsed. A useful real-world analogy of this overload is the behavior of a ferry leaving the dock when all seats are taken, or at the scheduled time of departure, whichever event occurs first.

Declaration

public static ISubscribable<IList<TSource>> Buffer<TSource>(this ISubscribable<TSource> source, TimeSpan duration, int count)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate buffers for.
System.TimeSpan	duration	Maximum duration of a buffer.
System.Int32	count	Maximum number of elements per buffer.

Returns

Type	Description
ISubscribable<System.Collections.Generic.IList<TSource>>	Observable sequence containing buffers over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Buffer<TSource>(ISubscribable<TSource>, TimeSpan, TimeSpan)

Partitions the source sequence into buffers based on the specified buffer duration and time shift.

Declaration

public static ISubscribable<IList<TSource>> Buffer<TSource>(this ISubscribable<TSource> source, TimeSpan duration, TimeSpan shift)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate buffers for.
System.TimeSpan	duration	Duration of a buffer.
System.TimeSpan	shift	Time shift between one buffer and the next.

Returns

Type	Description
ISubscribable<System.Collections.Generic.IList<TSource>>	Observable sequence containing buffers of the specified duration over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, ISubscribable<TSource11> source11, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
ISubscribable<TSource11>	source11	Eleventh observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TSource11
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, ISubscribable<TSource11> source11, ISubscribable<TSource12> source12, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
ISubscribable<TSource11>	source11	Eleventh observable input sequence.
ISubscribable<TSource12>	source12	Twelfth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TSource11
TSource12
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, ISubscribable<TSource11> source11, ISubscribable<TSource12> source12, ISubscribable<TSource13> source13, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
ISubscribable<TSource11>	source11	Eleventh observable input sequence.
ISubscribable<TSource12>	source12	Twelfth observable input sequence.
ISubscribable<TSource13>	source13	Thirteenth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TSource11
TSource12
TSource13
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, ISubscribable<TSource14>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, ISubscribable<TSource11> source11, ISubscribable<TSource12> source12, ISubscribable<TSource13> source13, ISubscribable<TSource14> source14, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
ISubscribable<TSource11>	source11	Eleventh observable input sequence.
ISubscribable<TSource12>	source12	Twelfth observable input sequence.
ISubscribable<TSource13>	source13	Thirteenth observable input sequence.
ISubscribable<TSource14>	source14	Fourteenth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TSource11
TSource12
TSource13
TSource14
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, ISubscribable<TSource14>, ISubscribable<TSource15>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, ISubscribable<TSource11> source11, ISubscribable<TSource12> source12, ISubscribable<TSource13> source13, ISubscribable<TSource14> source14, ISubscribable<TSource15> source15, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
ISubscribable<TSource11>	source11	Eleventh observable input sequence.
ISubscribable<TSource12>	source12	Twelfth observable input sequence.
ISubscribable<TSource13>	source13	Thirteenth observable input sequence.
ISubscribable<TSource14>	source14	Fourteenth observable input sequence.
ISubscribable<TSource15>	source15	Fifteenth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TSource11
TSource12
TSource13
TSource14
TSource15
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, ISubscribable<TSource9>, ISubscribable<TSource10>, ISubscribable<TSource11>, ISubscribable<TSource12>, ISubscribable<TSource13>, ISubscribable<TSource14>, ISubscribable<TSource15>, ISubscribable<TSource16>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, ISubscribable<TSource9> source9, ISubscribable<TSource10> source10, ISubscribable<TSource11> source11, ISubscribable<TSource12> source12, ISubscribable<TSource13> source13, ISubscribable<TSource14> source14, ISubscribable<TSource15> source15, ISubscribable<TSource16> source16, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
ISubscribable<TSource9>	source9	Ninth observable input sequence.
ISubscribable<TSource10>	source10	Tenth observable input sequence.
ISubscribable<TSource11>	source11	Eleventh observable input sequence.
ISubscribable<TSource12>	source12	Twelfth observable input sequence.
ISubscribable<TSource13>	source13	Thirteenth observable input sequence.
ISubscribable<TSource14>	source14	Fourteenth observable input sequence.
ISubscribable<TSource15>	source15	Fifteenth observable input sequence.
ISubscribable<TSource16>	source16	Sixteenth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TSource9
TSource10
TSource11
TSource12
TSource13
TSource14
TSource15
TSource16
TResult

CombineLatest<TSource1, TSource2, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, Func<TSource1, TSource2, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, Func<TSource1, TSource2, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
System.Func<TSource1, TSource2, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TResult

CombineLatest<TSource1, TSource2, TSource3, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, Func<TSource1, TSource2, TSource3, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, Func<TSource1, TSource2, TSource3, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
System.Func<TSource1, TSource2, TSource3, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, Func<TSource1, TSource2, TSource3, TSource4, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, Func<TSource1, TSource2, TSource3, TSource4, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TResult

CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(ISubscribable<TSource1>, ISubscribable<TSource2>, ISubscribable<TSource3>, ISubscribable<TSource4>, ISubscribable<TSource5>, ISubscribable<TSource6>, ISubscribable<TSource7>, ISubscribable<TSource8>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>)

Combines the latest observed element of each input sequence using the specified selector function upon receiving any element on any of the input sequences.

Declaration

public static ISubscribable<TResult> CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(this ISubscribable<TSource1> source1, ISubscribable<TSource2> source2, ISubscribable<TSource3> source3, ISubscribable<TSource4> source4, ISubscribable<TSource5> source5, ISubscribable<TSource6> source6, ISubscribable<TSource7> source7, ISubscribable<TSource8> source8, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource1>	source1	First observable input sequence.
ISubscribable<TSource2>	source2	Second observable input sequence.
ISubscribable<TSource3>	source3	Third observable input sequence.
ISubscribable<TSource4>	source4	Fourth observable input sequence.
ISubscribable<TSource5>	source5	Fifth observable input sequence.
ISubscribable<TSource6>	source6	Sixth observable input sequence.
ISubscribable<TSource7>	source7	Seventh observable input sequence.
ISubscribable<TSource8>	source8	Eighth observable input sequence.
System.Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>	selector	Selector function to apply to the latest observer element of each input sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the selector function to the latest value of each input sequence whenever any input sequence receives an element.

Type Parameters

Name	Description
TSource1
TSource2
TSource3
TSource4
TSource5
TSource6
TSource7
TSource8
TResult

Count<TSource>(ISubscribable<TSource>)

Aggregates the source sequence to count the number of elements. The result is represented as a 32-bit integer.

Declaration

public static ISubscribable<int> Count<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to count.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with an integer value representing the number of elements in the sequence. If the source sequence is empty, an element with value 0 is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Count<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Aggregates the source sequence to count the number of elements that match the specified predicate. The result is represented as a 32-bit integer.

Declaration

public static ISubscribable<int> Count<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to count based on the specified predicate.
System.Func<TSource, System.Boolean>	predicate	Predicate function to apply to each element of the source sequence. Elements that match the predicate will be counted.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with an integer value representing the number of elements in the sequence that match the predicate. If the source sequence does not contain any elements matching the predicate, an element with value 0 is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

DelaySubscription<TSource>(ISubscribable<TSource>, DateTimeOffset)

Delays the subscription to the source sequence until the specified absolute due time.

Declaration

public static ISubscribable<TSource> DelaySubscription<TSource>(this ISubscribable<TSource> source, DateTimeOffset dueTime)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to delay subscription to.
System.DateTimeOffset	dueTime	Time when a subscription to the source sequence should be made.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's notifications after it has been subscribed to at the specified due time.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

DelaySubscription<TSource>(ISubscribable<TSource>, TimeSpan)

Delays the subscription to the source sequence until the specified relative due time.

Declaration

public static ISubscribable<TSource> DelaySubscription<TSource>(this ISubscribable<TSource> source, TimeSpan dueTime)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to delay subscription to. This time is relative to the time of subscription.
System.TimeSpan	dueTime	Time when a subscription to the source sequence should be made.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's notifications after it has been subscribed to at the specified due time.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Exceptions

Type	Condition
System.ArgumentOutOfRangeException	Thrown when the due time is less than zero.

DistinctUntilChanged<TSource>(ISubscribable<TSource>)

Propagates adjacent distinct elements from the source sequence using the default comparer for elements.

Declaration

public static ISubscribable<TSource> DistinctUntilChanged<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's elements provided the current element is different from the immediately preceding element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

DistinctUntilChanged<TSource>(ISubscribable<TSource>, IEqualityComparer<TSource>)

Propagates adjacent distinct elements from the source sequence using the specified comparer for elements.

Declaration

public static ISubscribable<TSource> DistinctUntilChanged<TSource>(this ISubscribable<TSource> source, IEqualityComparer<TSource> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate.
System.Collections.Generic.IEqualityComparer<TSource>	comparer	Comparer used to compare whether an element is the same as the preceding element.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's elements provided the current element is different from the immediately preceding element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

DistinctUntilChanged<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>)

Propagates adjacent distinct elements from the source sequence based on the comparison of a projected key and using the default comparer for keys.

Declaration

public static ISubscribable<TSource> DistinctUntilChanged<TSource, TKey>(this ISubscribable<TSource> source, Func<TSource, TKey> keySelector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate.
System.Func<TSource, TKey>	keySelector	Selector function to apply to each element to obtain a key used for equality comparison between elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's elements provided the current element is different from the immediately preceding element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TKey	Type of the keys to compare elements by.

DistinctUntilChanged<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)

Propagates adjacent distinct elements from the source sequence based on the comparison of a projected key and using the specified comparer for keys.

Declaration

public static ISubscribable<TSource> DistinctUntilChanged<TSource, TKey>(this ISubscribable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate.
System.Func<TSource, TKey>	keySelector	Selector function to apply to each element to obtain a key used for equality comparison between elements.
System.Collections.Generic.IEqualityComparer<TKey>	comparer	Comparer used to compare whether an element is the same as the preceding element based on the keys obtained for these elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's elements provided the current element is different from the immediately preceding element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TKey	Type of the keys to compare elements by.

Do<TSource>(ISubscribable<TSource>, Action<TSource>)

Observes the source sequence's elements using the specified action and propagates the source's notifications to the resulting observable sequence.

Declaration

public static ISubscribable<TSource> Do<TSource>(this ISubscribable<TSource> source, Action<TSource> onNext)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to observe notifications for.
System.Action<TSource>	onNext	Action to process elements in the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source's notifications after they've been observed by the specified actions.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Do<TSource>(ISubscribable<TSource>, Action<TSource>, Action)

Observes the source sequence's elements and completion notifications using the specified actions and propagates the source's notifications to the resulting observable sequence.

Declaration

public static ISubscribable<TSource> Do<TSource>(this ISubscribable<TSource> source, Action<TSource> onNext, Action onCompleted)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to observe notifications for.
System.Action<TSource>	onNext	Action to process elements in the source sequence.
System.Action	onCompleted	Action to process completion notifications in the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source's notifications after they've been observed by the specified actions.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Do<TSource>(ISubscribable<TSource>, Action<TSource>, Action<Exception>)

Observes the source sequence's elements and error notifications using the specified actions and propagates the source's notifications to the resulting observable sequence.

Declaration

public static ISubscribable<TSource> Do<TSource>(this ISubscribable<TSource> source, Action<TSource> onNext, Action<Exception> onError)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to observe notifications for.
System.Action<TSource>	onNext	Action to process elements in the source sequence.
System.Action<System.Exception>	onError	Action to process error notifications in the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source's notifications after they've been observed by the specified actions.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Do<TSource>(ISubscribable<TSource>, Action<TSource>, Action<Exception>, Action)

Observes the source sequence's notifications using the specified actions and propagates the source's notifications to the resulting observable sequence.

Declaration

public static ISubscribable<TSource> Do<TSource>(this ISubscribable<TSource> source, Action<TSource> onNext, Action<Exception> onError, Action onCompleted)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to observe notifications for.
System.Action<TSource>	onNext	Action to process elements in the source sequence.
System.Action<System.Exception>	onError	Action to process error notifications in the source sequence.
System.Action	onCompleted	Action to process completion notifications in the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source's notifications after they've been observed by the specified actions.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Do<TSource>(ISubscribable<TSource>, IObserver<TSource>)

Observes the source sequence's notifications using the specified observer and propagates the source's notifications to the resulting observable sequence.

Declaration

public static ISubscribable<TSource> Do<TSource>(this ISubscribable<TSource> source, IObserver<TSource> observer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to observe notifications for.
System.IObserver<TSource>	observer	Observer used to observe the source's notifications.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source's notifications after they've been fed to the observer.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Do<TSource, TNotification>(ISubscribable<TSource>, Func<TSource, TNotification>, IObserver<TNotification>)

Observes the source sequence's notifications - after projection of its elements - using the specified observer and propagates the source's notifications to the resulting observable sequence.

Declaration

public static ISubscribable<TSource> Do<TSource, TNotification>(this ISubscribable<TSource> source, Func<TSource, TNotification> selector, IObserver<TNotification> observer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to observe notifications for.
System.Func<TSource, TNotification>	selector	Selector function used to project the source sequence's elements.
System.IObserver<TNotification>	observer	Observer used to observe the source's notifications after projection.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source's notifications after they've been projected and fed to the observer.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TNotification	Type of the result of the projection.

Empty<TResult>()

Returns an observable sequence representing an empty sequence by producing an OnCompleted notification.

Declaration

public static ISubscribable<TResult> Empty<TResult>()

Returns

Type	Description
ISubscribable<TResult>	An empty observable sequence.

Type Parameters

Name	Description
TResult	Type of the elements in the resulting sequence.

Finally<TSource>(ISubscribable<TSource>, Action)

Invokes the specified action upon exceptional or successful termination of the source sequence.

Declaration

public static ISubscribable<TSource> Finally<TSource>(this ISubscribable<TSource> source, Action action)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to apply the finally behavior to.
System.Action	action	Action to invoke upon termination of the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the notification of the source sequence and invoking the specified action upon the sequence's termination.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

FirstAsync<TSource>(ISubscribable<TSource>)

Returns a sequence propagating the first element of the source sequence. If the source sequence is empty, an InvalidOperatingException error is propagated.

Declaration

public static ISubscribable<TSource> FirstAsync<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to propagate the first element for.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the first element of the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

FirstAsync<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Returns a sequence propagating the first element of the source sequence that matches the specified predicate. If the source sequence has no element matching the predicate, an InvalidOperatingException error is propagated.

Declaration

public static ISubscribable<TSource> FirstAsync<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to propagate the first element matching the predicate for.
System.Func<TSource, System.Boolean>	predicate	Predicate to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the first element of the source sequence that matches the specified predicate.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

FirstOrDefaultAsync<TSource>(ISubscribable<TSource>)

Returns a sequence propagating the first element of the source sequence. If the source sequence is empty, a default value is produced.

Declaration

public static ISubscribable<TSource> FirstOrDefaultAsync<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to propagate the first element for.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the first element of the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

FirstOrDefaultAsync<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Returns a sequence propagating the first element of the source sequence that matches the specified predicate. If the source sequence has no element matching the predicate, a default value is produced.

Declaration

public static ISubscribable<TSource> FirstOrDefaultAsync<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to propagate the first element matching the predicate for.
System.Func<TSource, System.Boolean>	predicate	Predicate to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the first element of the source sequence that matches the specified predicate.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

GroupBy<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>)

Groups the elements in the observable sequence by a computed key.

Declaration

public static ISubscribable<IGroupedSubscribable<TKey, TSource>> GroupBy<TSource, TKey>(this ISubscribable<TSource> source, Func<TSource, TKey> keySelector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Observable sequence whose elements to group.
System.Func<TSource, TKey>	keySelector	Key selector function to obtain a key for each element.

Returns

Type	Description
ISubscribable<IGroupedSubscribable<TKey, TSource>>	Observable sequence of groups, which are observable sequences themselves.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TKey	Type of the keys to group by.

GroupBy<TSource, TKey>(ISubscribable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)

Groups the elements in the observable sequence by a computed key which gets compared to other keys using the specified comparer.

Declaration

public static ISubscribable<IGroupedSubscribable<TKey, TSource>> GroupBy<TSource, TKey>(this ISubscribable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Observable sequence whose elements to group.
System.Func<TSource, TKey>	keySelector	Key selector function to obtain a key for each element.
System.Collections.Generic.IEqualityComparer<TKey>	comparer	Comparer used to compare keys for equality.

Returns

Type	Description
ISubscribable<IGroupedSubscribable<TKey, TSource>>	Observable sequence of groups, which are observable sequences themselves.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TKey	Type of the keys to group by.

GroupBy<TSource, TKey, TElement>(ISubscribable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)

Groups the elements in the observable sequence by a computed key.

Declaration

public static ISubscribable<IGroupedSubscribable<TKey, TElement>> GroupBy<TSource, TKey, TElement>(this ISubscribable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Observable sequence whose elements to group.
System.Func<TSource, TKey>	keySelector	Key selector function to obtain a key for each element.
System.Func<TSource, TElement>	elementSelector	Element selector function to obtain a group element for each input element.

Returns

Type	Description
ISubscribable<IGroupedSubscribable<TKey, TElement>>	Observable sequence of groups, which are observable sequences themselves.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TKey	Type of the keys to group by.
TElement	Type of the elements produced in the groups.

GroupBy<TSource, TKey, TElement>(ISubscribable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>)

Groups the elements in the observable sequence by a computed key which gets compared to other keys using the specified comparer.

Declaration

public static ISubscribable<IGroupedSubscribable<TKey, TElement>> GroupBy<TSource, TKey, TElement>(this ISubscribable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Observable sequence whose elements to group.
System.Func<TSource, TKey>	keySelector	Key selector function to obtain a key for each element.
System.Func<TSource, TElement>	elementSelector	Element selector function to obtain a group element for each input element.
System.Collections.Generic.IEqualityComparer<TKey>	comparer	Comparer used to compare keys for equality.

Returns

Type	Description
ISubscribable<IGroupedSubscribable<TKey, TElement>>	Observable sequence of groups, which are observable sequences themselves.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TKey	Type of the keys to group by.
TElement	Type of the elements produced in the groups.

IsEmpty<TSource>(ISubscribable<TSource>)

Aggregates the source sequence to determine whether it is empty.

Declaration

public static ISubscribable<bool> IsEmpty<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to check for the presence of elements.

Returns

Type	Description
ISubscribable<System.Boolean>	Observable sequence containing a single element with value true if the source sequence is empty; otherwise a single element with value false.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

LongCount<TSource>(ISubscribable<TSource>)

Aggregates the source sequence to count the number of elements. The result is represented as a 64-bit integer.

Declaration

public static ISubscribable<long> LongCount<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to count.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with an integer value representing the number of elements in the sequence. If the source sequence is empty, an element with value 0 is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

LongCount<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Aggregates the source sequence to count the number of elements that match the specified predicate. The result is represented as a 64-bit integer.

Declaration

public static ISubscribable<long> LongCount<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to count based on the specified predicate.
System.Func<TSource, System.Boolean>	predicate	Predicate function to apply to each element of the source sequence. Elements that match the predicate will be counted.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with an integer value representing the number of elements in the sequence that match the predicate. If the source sequence does not contain any elements matching the predicate, an element with value 0 is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max(ISubscribable<Decimal>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<Decimal> Max(this ISubscribable<Decimal> source)

Parameters

Type	Name	Description
ISubscribable<System.Decimal>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Max(ISubscribable<Double>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<double> Max(this ISubscribable<double> source)

Parameters

Type	Name	Description
ISubscribable<System.Double>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Max(ISubscribable<Int32>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<int> Max(this ISubscribable<int> source)

Parameters

Type	Name	Description
ISubscribable<System.Int32>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Max(ISubscribable<Int64>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<long> Max(this ISubscribable<long> source)

Parameters

Type	Name	Description
ISubscribable<System.Int64>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Max(ISubscribable<Nullable<Decimal>>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<Nullable<Decimal>> Max(this ISubscribable<Nullable<Decimal>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Decimal>>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Max(ISubscribable<Nullable<Double>>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<Nullable<double>> Max(this ISubscribable<Nullable<double>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Double>>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Max(ISubscribable<Nullable<Int32>>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<Nullable<int>> Max(this ISubscribable<Nullable<int>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int32>>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int32>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Max(ISubscribable<Nullable<Int64>>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<Nullable<long>> Max(this ISubscribable<Nullable<long>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int64>>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int64>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Max(ISubscribable<Nullable<Single>>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<Nullable<float>> Max(this ISubscribable<Nullable<float>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Single>>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Max(ISubscribable<Single>)

Aggregates the source sequence to return the largest element's value.

Declaration

public static ISubscribable<float> Max(this ISubscribable<float> source)

Parameters

Type	Name	Description
ISubscribable<System.Single>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Max<TSource>(ISubscribable<TSource>)

Aggregates the source sequence to return the largest element's value determined using the default comparer.

Declaration

public static ISubscribable<TSource> Max<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest element to obtain.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, IComparer<TSource>)

Aggregates the source sequence to return the largest element's value determined using the specified comparer.

Declaration

public static ISubscribable<TSource> Max<TSource>(this ISubscribable<TSource> source, IComparer<TSource> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest element to obtain.
System.Collections.Generic.IComparer<TSource>	comparer	Comparer used to determine the element with the largest value.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Decimal> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, Decimal> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Decimal>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Double>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<double> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, double> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Double>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<int> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, int> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Int32>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<long> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, long> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Int64>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<Decimal>> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<Decimal>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Decimal>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<double>> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<double>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Double>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<int>> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<int>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int32>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int32>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<long>> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<long>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int64>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int64>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<float>> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<float>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Single>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Max<TSource>(ISubscribable<TSource>, Func<TSource, Single>)

Aggregates the source sequence to return the largest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<float> Max<TSource>(this ISubscribable<TSource> source, Func<TSource, float> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose largest value of projected elements to obtain.
System.Func<TSource, System.Single>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the largest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Merge<TSource>(ISubscribable<TSource>, ISubscribable<TSource>)

Merges the elements in the specified sequences.

Declaration

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

Parameters

Type	Name	Description
ISubscribable<TSource>	first	The first observable sequence whose elements should be merged.
ISubscribable<TSource>	second	The second observable sequence whose elements should be merged.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the elements of the specified source sequences.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequences.

Merge<TSource>(ISubscribable<TSource>[])

Merges the elements in the specified sequences.

Declaration

public static ISubscribable<TSource> Merge<TSource>(params ISubscribable<TSource>[] sources)

Parameters

Type	Name	Description
ISubscribable<TSource>[]	sources	Array of sequences whose elements should be merged.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the elements of the specified source sequences.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequences.

Merge<TSource>(ISubscribable<ISubscribable<TSource>>)

Merges the elements in the inner sequences produced by the specified higher-order sequence.

Declaration

public static ISubscribable<TSource> Merge<TSource>(this ISubscribable<ISubscribable<TSource>> sources)

Parameters

Type	Name	Description
ISubscribable<ISubscribable<TSource>>	sources	Observable sequence producing inner sequences whose elements should be merged.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the elements of the source sequences produced by the specified higher-order sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequences.

Min(ISubscribable<Decimal>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<Decimal> Min(this ISubscribable<Decimal> source)

Parameters

Type	Name	Description
ISubscribable<System.Decimal>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Min(ISubscribable<Double>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<double> Min(this ISubscribable<double> source)

Parameters

Type	Name	Description
ISubscribable<System.Double>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Min(ISubscribable<Int32>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<int> Min(this ISubscribable<int> source)

Parameters

Type	Name	Description
ISubscribable<System.Int32>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Min(ISubscribable<Int64>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<long> Min(this ISubscribable<long> source)

Parameters

Type	Name	Description
ISubscribable<System.Int64>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Min(ISubscribable<Nullable<Decimal>>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<Nullable<Decimal>> Min(this ISubscribable<Nullable<Decimal>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Decimal>>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Min(ISubscribable<Nullable<Double>>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<Nullable<double>> Min(this ISubscribable<Nullable<double>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Double>>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Min(ISubscribable<Nullable<Int32>>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<Nullable<int>> Min(this ISubscribable<Nullable<int>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int32>>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int32>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Min(ISubscribable<Nullable<Int64>>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<Nullable<long>> Min(this ISubscribable<Nullable<long>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int64>>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int64>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Min(ISubscribable<Nullable<Single>>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<Nullable<float>> Min(this ISubscribable<Nullable<float>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Single>>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Min(ISubscribable<Single>)

Aggregates the source sequence to return the smallest element's value.

Declaration

public static ISubscribable<float> Min(this ISubscribable<float> source)

Parameters

Type	Name	Description
ISubscribable<System.Single>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Min<TSource>(ISubscribable<TSource>)

Aggregates the source sequence to return the smallest element's value determined using the default comparer.

Declaration

public static ISubscribable<TSource> Min<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest element to obtain.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, IComparer<TSource>)

Aggregates the source sequence to return the smallest element's value determined using the specified comparer.

Declaration

public static ISubscribable<TSource> Min<TSource>(this ISubscribable<TSource> source, IComparer<TSource> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest element to obtain.
System.Collections.Generic.IComparer<TSource>	comparer	Comparer used to determine the element with the smallest value.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Decimal> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, Decimal> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Decimal>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Double>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<double> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, double> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Double>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<int> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, int> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Int32>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<long> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, long> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Int64>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<Decimal>> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<Decimal>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Decimal>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<double>> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<double>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Double>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<int>> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<int>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int32>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int32>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<long>> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<long>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int64>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int64>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<float>> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<float>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Single>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, a null value is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Min<TSource>(ISubscribable<TSource>, Func<TSource, Single>)

Aggregates the source sequence to return the smallest value obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<float> Min<TSource>(this ISubscribable<TSource> source, Func<TSource, float> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose smallest value of projected elements to obtain.
System.Func<TSource, System.Single>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the smallest value found in the source sequence. If the source sequence is empty, an error of type System.InvalidOperationException is propagated.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Never<TResult>()

Returns an observable sequence that never produces any notification. Such a sequence can be used to represent an infinite duration.

Declaration

public static ISubscribable<TResult> Never<TResult>()

Returns

Type	Description
ISubscribable<TResult>	An observable sequence that never produces any notification.

Type Parameters

Name	Description
TResult	Type of the elements in the resulting sequence.

Retry<TSource>(ISubscribable<TSource>)

Retries receiving elements from the source sequence upon encountering an error notification by resubscribing to it.

Declaration

public static ISubscribable<TSource> Retry<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to apply retry behavior to.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating elements from the source sequence subscription(s).

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Retry<TSource>(ISubscribable<TSource>, Int32)

Retries receiving elements from the source sequence upon encountering an error notification by resubscribing to it for a specified maximum number of times.

Declaration

public static ISubscribable<TSource> Retry<TSource>(this ISubscribable<TSource> source, int retryCount)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to apply retry behavior to.
System.Int32	retryCount	Maximum number of times to subscribe to the source sequence; a value of 1 indicates no retry.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating elements from the source sequence subscription(s).

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Return<TResult>(TResult)

Returns an observable sequence that produces a single OnNext notification with the specified value.

Declaration

public static ISubscribable<TResult> Return<TResult>(TResult value)

Parameters

Type	Name	Description
TResult	value	The single value the resulting sequence should produce.

Returns

Type	Description
ISubscribable<TResult>	An observable sequence that produces a single element with the specified value, followed by a completion notification.

Type Parameters

Name	Description
TResult	Type of the elements in the resulting sequence.

Sample<TSource>(ISubscribable<TSource>, TimeSpan)

Samples the elements in the source sequence using the specified period. For each sampling period, the last element (if any) observed in the sampling period will be propagated.

Declaration

public static ISubscribable<TSource> Sample<TSource>(this ISubscribable<TSource> source, TimeSpan period)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to sample.
System.TimeSpan	period	Sampling period.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing elements of the source sequence obtained from sampling with the specified period.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sample<TSource, TSample>(ISubscribable<TSource>, ISubscribable<TSample>)

Samples the elements in the source sequence using the specified sampling sequence. For each sampling period, the last element (if any) observed in the sampling period will be propagated.

Declaration

public static ISubscribable<TSource> Sample<TSource, TSample>(this ISubscribable<TSource> source, ISubscribable<TSample> sampler)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to sample.
ISubscribable<TSample>	sampler	Sampling sequence whose elements cause samples elements from the source sequence to be propagated to the result sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing elements of the source sequence obtained from sampling using the specified sampling sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TSample	Type of the elements in the sampling sequence.

Scan<TSource>(ISubscribable<TSource>, Func<TSource, TSource, TSource>)

Produces a sequence with a rolling aggregates of the elements in the source sequence using the specified aggregation function.

Declaration

public static ISubscribable<TSource> Scan<TSource>(this ISubscribable<TSource> source, Func<TSource, TSource, TSource> aggregate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to aggregate.
System.Func<TSource, TSource, TSource>	aggregate	Aggregation function used to combine the running aggregation result with each consecutive element.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing elements obtained from applying the rolling aggregate to the source sequence. If the source sequence is empty, an empty sequence is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Scan<TSource, TResult>(ISubscribable<TSource>, TResult, Func<TResult, TSource, TResult>)

Produces a sequence with a rolling aggregates of the elements in the source sequence starting from an initial seed value and using the specified aggregation function.

Declaration

public static ISubscribable<TResult> Scan<TSource, TResult>(this ISubscribable<TSource> source, TResult seed, Func<TResult, TSource, TResult> accumulate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to aggregate.
TResult	seed	Seed value of the aggregation.
System.Func<TResult, TSource, TResult>	accumulate	Aggregation function used to combine the running aggregation result with each consecutive element.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing elements obtained from applying the rolling aggregate to the source sequence. If the source sequence is empty, an empty sequence is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TResult	Type of the result of the aggregation.

Select<TSource, TResult>(ISubscribable<TSource>, Func<TSource, TResult>)

Projects elements in the source sequence using the specified selector function.

Declaration

public static ISubscribable<TResult> Select<TSource, TResult>(this ISubscribable<TSource> source, Func<TSource, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to project.
System.Func<TSource, TResult>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence with the projected elements from the source sequence using the specified selector function.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TResult	Type of the elements in the result sequence.

Select<TSource, TResult>(ISubscribable<TSource>, Func<TSource, Int32, TResult>)

Projects elements in the source sequence using the specified selector function that takes in an element index.

Declaration

public static ISubscribable<TResult> Select<TSource, TResult>(this ISubscribable<TSource> source, Func<TSource, int, TResult> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to project.
System.Func<TSource, System.Int32, TResult>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence with the projected elements from the source sequence using the specified selector function.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TResult	Type of the elements in the result sequence.

SelectMany<TSource, TResult>(ISubscribable<TSource>, Func<TSource, ISubscribable<TResult>>)

Merges the inner sequences obtained by projecting the source sequence's elements using the specified selector function.

Declaration

public static ISubscribable<TResult> SelectMany<TSource, TResult>(this ISubscribable<TSource> source, Func<TSource, ISubscribable<TResult>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to project onto inner sequences.
System.Func<TSource, ISubscribable<TResult>>	selector	Selector to apply to element in the source sequence in order to obtain an inner sequence.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing the merged elements from the inner sequences.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TResult	Type of the elements in the result sequence.

SelectMany<TSource, TCollection, TResult>(ISubscribable<TSource>, Func<TSource, ISubscribable<TCollection>>, Func<TSource, TCollection, TResult>)

Merges the inner sequences obtained by projecting the source sequence's elements using the specified collection selector function and by applying the specified result selector function.

Declaration

public static ISubscribable<TResult> SelectMany<TSource, TCollection, TResult>(this ISubscribable<TSource> source, Func<TSource, ISubscribable<TCollection>> collectionSelector, Func<TSource, TCollection, TResult> resultSelector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to project onto inner sequences.
System.Func<TSource, ISubscribable<TCollection>>	collectionSelector	Selector to apply to element in the source sequence in order to obtain an inner sequence.
System.Func<TSource, TCollection, TResult>	resultSelector	Result selector to combine an outer source sequence's element and an inner sequence's element in order to produce a result element.

Returns

Type	Description
ISubscribable<TResult>	Observable sequence containing the elements obtained from applying the result selector to pairs of outer and inner sequence elements.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TCollection	Type of the elements in the inner sequences.
TResult	Type of the elements in the result sequence.

SequenceEqual<TSource>(ISubscribable<TSource>, ISubscribable<TSource>)

Compares two observable sequences for pairwise equality of elements.

Declaration

public static ISubscribable<bool> SequenceEqual<TSource>(this ISubscribable<TSource> left, ISubscribable<TSource> right)

Parameters

Type	Name	Description
ISubscribable<TSource>	left	Left sequence whose elements to compare.
ISubscribable<TSource>	right	Right sequence whose elements to compare.

Returns

Type	Description
ISubscribable<System.Boolean>	Observable sequence containing a single Boolean value indicating whether the two sequences are equal in length and have pairwise equality of elements.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequences.

SequenceEqual<TSource>(ISubscribable<TSource>, ISubscribable<TSource>, IEqualityComparer<TSource>)

Compares two observable sequences for pairwise equality of elements.

Declaration

public static ISubscribable<bool> SequenceEqual<TSource>(this ISubscribable<TSource> left, ISubscribable<TSource> right, IEqualityComparer<TSource> comparer)

Parameters

Type	Name	Description
ISubscribable<TSource>	left	Left sequence whose elements to compare.
ISubscribable<TSource>	right	Right sequence whose elements to compare.
System.Collections.Generic.IEqualityComparer<TSource>	comparer	Equality comparer used to compare elements from both sequences.

Returns

Type	Description
ISubscribable<System.Boolean>	Observable sequence containing a single Boolean value indicating whether the two sequences are equal in length and have pairwise equality of elements.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequences.

Skip<TSource>(ISubscribable<TSource>, Int32)

Skips the specified number of elements from the start of the source sequence. If the sequence contains less elements than the number specified, an empty sequence is returned.

Declaration

public static ISubscribable<TSource> Skip<TSource>(this ISubscribable<TSource> source, int count)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate to the result sequence.
System.Int32	count	Number of elements to skip from the start of the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence skipping the specified number of elements from the start of the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Skip<TSource>(ISubscribable<TSource>, TimeSpan)

Skips the elements in the source sequence for the specified duration.

Declaration

public static ISubscribable<TSource> Skip<TSource>(this ISubscribable<TSource> source, TimeSpan dueTime)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to skip elements for.
System.TimeSpan	dueTime	Time when elements in the source sequence should be start to propagated to the resulting sequence. This time is relative to the time of subscription.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the elements of the source sequence after the specified relative due time.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

SkipUntil<TSource>(ISubscribable<TSource>, DateTimeOffset)

Skips the elements in the source sequence until the specified start time.

Declaration

public static ISubscribable<TSource> SkipUntil<TSource>(this ISubscribable<TSource> source, DateTimeOffset startTime)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to skip elements for.
System.DateTimeOffset	startTime	Time when elements in the source sequence should start to be propagated to the resulting sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the elements of the source sequence after the specified absolute start time.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

SkipUntil<TSource, TOther>(ISubscribable<TSource>, ISubscribable<TOther>)

Skips elements in the source sequence until the triggering sequence produces an element.

Declaration

public static ISubscribable<TSource> SkipUntil<TSource, TOther>(this ISubscribable<TSource> source, ISubscribable<TOther> triggeringSource)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to skip until the triggering sequence produces an element.
ISubscribable<TOther>	triggeringSource	Triggering sequence to produce a signal to start propagating the source sequence's elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's elements after the triggering sequence produces an element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TOther	Type of the elements in the triggering sequence.

SkipWhile<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Skips elements from the source sequence until the specified predicate holds for an element.

Declaration

public static ISubscribable<TSource> SkipWhile<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate to the result sequence.
System.Func<TSource, System.Boolean>	predicate	Predicate function to apply to each element in the sequence to determine when to start propagating elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the source sequence's elements starting from the first element matching the predicate.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

SkipWhile<TSource>(ISubscribable<TSource>, Func<TSource, Int32, Boolean>)

Skips elements from the source sequence until the specified indexed predicate holds for an element.

Declaration

public static ISubscribable<TSource> SkipWhile<TSource>(this ISubscribable<TSource> source, Func<TSource, int, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate to the result sequence.
System.Func<TSource, System.Int32, System.Boolean>	predicate	Predicate function to apply to each element in the sequence to determine when to start propagating elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the source sequence's elements starting from the first element matching the predicate.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

StartWith<TSource>(ISubscribable<TSource>, TSource[])

Prepends the source sequence with the specified values.

Declaration

public static ISubscribable<TSource> StartWith<TSource>(this ISubscribable<TSource> source, params TSource[] values)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to subscribe to and propagate elements for after the specified values have been produced in the resulting sequence.
TSource[]	values	Values to prepend the source sequence with.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence producing the specified values, followed by the elements of the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum(ISubscribable<Decimal>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<Decimal> Sum(this ISubscribable<Decimal> source)

Parameters

Type	Name	Description
ISubscribable<System.Decimal>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Double>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<double> Sum(this ISubscribable<double> source)

Parameters

Type	Name	Description
ISubscribable<System.Double>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Int32>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<int> Sum(this ISubscribable<int> source)

Parameters

Type	Name	Description
ISubscribable<System.Int32>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Int64>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<long> Sum(this ISubscribable<long> source)

Parameters

Type	Name	Description
ISubscribable<System.Int64>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Nullable<Decimal>>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<Nullable<Decimal>> Sum(this ISubscribable<Nullable<Decimal>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Decimal>>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Nullable<Double>>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<Nullable<double>> Sum(this ISubscribable<Nullable<double>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Double>>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Nullable<Int32>>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<Nullable<int>> Sum(this ISubscribable<Nullable<int>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int32>>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int32>>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Nullable<Int64>>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<Nullable<long>> Sum(this ISubscribable<Nullable<long>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Int64>>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int64>>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Nullable<Single>>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<Nullable<float>> Sum(this ISubscribable<Nullable<float>> source)

Parameters

Type	Name	Description
ISubscribable<System.Nullable<System.Single>>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum(ISubscribable<Single>)

Aggregates the source sequence to return the sum of the element values.

Declaration

public static ISubscribable<float> Sum(this ISubscribable<float> source)

Parameters

Type	Name	Description
ISubscribable<System.Single>	source	Source sequence whose sum of elements to obtain.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the sum of all values in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Decimal>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Decimal> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, Decimal> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Decimal>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Decimal>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Double>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<double> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, double> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Double>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Double>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Int32>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<int> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, int> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Int32>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Int32>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Int64>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<long> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, long> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Int64>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Decimal>>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<Decimal>> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<Decimal>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Decimal>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Decimal>>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Double>>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<double>> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<double>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Double>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Double>>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int32>>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<int>> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<int>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int32>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int32>>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Int64>>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<long>> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<long>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Int64>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Int64>>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Nullable<Single>>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<Nullable<float>> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, Nullable<float>> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Nullable<System.Single>>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Nullable<System.Single>>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Sum<TSource>(ISubscribable<TSource>, Func<TSource, Single>)

Aggregates the source sequence to return the sum of the values obtained from applying the specified selector function to each element in the source sequence.

Declaration

public static ISubscribable<float> Sum<TSource>(this ISubscribable<TSource> source, Func<TSource, float> selector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose sum of projected elements to obtain.
System.Func<TSource, System.Single>	selector	Selector function to apply to each element in the source sequence.

Returns

Type	Description
ISubscribable<System.Single>	Observable sequence containing a single element with the sum of all projected values in the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Switch<TSource>(ISubscribable<ISubscribable<TSource>>)

Switches to the latest inner sequence produced by the specified higher-order sequence and propagates the latest inner sequence's elements.

Declaration

public static ISubscribable<TSource> Switch<TSource>(this ISubscribable<ISubscribable<TSource>> sources)

Parameters

Type	Name	Description
ISubscribable<ISubscribable<TSource>>	sources	Observable sequence producing inner sequences that should be switched over.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the elements of the latest sequence produced by the specified higher-order sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequences.

Take<TSource>(ISubscribable<TSource>, Int32)

Takes the specified number of elements from the start of the source sequence. If the sequence contains less elements than the number specified, all elements are returned.

Declaration

public static ISubscribable<TSource> Take<TSource>(this ISubscribable<TSource> source, int count)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate to the result sequence.
System.Int32	count	Number of elements to propagate from the start of the source sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the specified number of elements from the start of the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Take<TSource>(ISubscribable<TSource>, TimeSpan)

Takes the elements from the source sequence for the specified duration.

Declaration

public static ISubscribable<TSource> Take<TSource>(this ISubscribable<TSource> source, TimeSpan dueTime)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to take elements from.
System.TimeSpan	dueTime	Time when elements in the source sequence should be stop to propagated to the resulting sequence. This time is relative to the time of subscription.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the elements of the source sequence for the specified relative due time.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

TakeUntil<TSource>(ISubscribable<TSource>, DateTimeOffset)

Takes the elements from the source sequence until the specified end time.

Declaration

public static ISubscribable<TSource> TakeUntil<TSource>(this ISubscribable<TSource> source, DateTimeOffset endTime)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to take elements from.
System.DateTimeOffset	endTime	Time when elements in the source sequence should stop to be propagated to the resulting sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the elements of the source sequence until the specified absolute end time.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

TakeUntil<TSource, TOther>(ISubscribable<TSource>, ISubscribable<TOther>)

Takes elements from the source sequence until the triggering sequence produces an element.

Declaration

public static ISubscribable<TSource> TakeUntil<TSource, TOther>(this ISubscribable<TSource> source, ISubscribable<TOther> triggeringSource)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to take until the triggering sequence produces an element.
ISubscribable<TOther>	triggeringSource	Triggering sequence to produce a signal to stop propagating the source sequence's elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence propagating the source sequence's elements until the triggering sequence produces an element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TOther	Type of the elements in the triggering sequence.

TakeWhile<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Takes elements from the source sequence as long as the specified predicate holds for its elements.

Declaration

public static ISubscribable<TSource> TakeWhile<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate to the result sequence.
System.Func<TSource, System.Boolean>	predicate	Predicate function to apply to each element in the sequence to determine when to stop propagating elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the source sequence's elements until the predicate doesn't match an element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

TakeWhile<TSource>(ISubscribable<TSource>, Func<TSource, Int32, Boolean>)

Takes elements from the source sequence as long as the specified indexed predicate holds for its elements.

Declaration

public static ISubscribable<TSource> TakeWhile<TSource>(this ISubscribable<TSource> source, Func<TSource, int, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to propagate to the result sequence.
System.Func<TSource, System.Int32, System.Boolean>	predicate	Predicate function to apply to each element in the sequence to determine when to stop propagating elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the source sequence's elements until the predicate doesn't match an element.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Throttle<TSource>(ISubscribable<TSource>, TimeSpan)

Throttles the elements in the source sequence using the specified throttling duration. If an element is received in less than the throttling duration from the previous element, the throttling timer is reset and the previous element is dropped.

Declaration

public static ISubscribable<TSource> Throttle<TSource>(this ISubscribable<TSource> source, TimeSpan duration)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to throttle elements for.
System.TimeSpan	duration	Duration of a throttling period.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence with the throttled elements from the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Throttle<TSource, TThrottle>(ISubscribable<TSource>, Func<TSource, ISubscribable<TThrottle>>)

Throttles the input sequence based on throttling duration sequences obtained using the specified selector. If an element is received in before the throttling sequence obtained from the previous element has produced an element, the throttling selector is applied to the newly received element and the previous element is dropped.

Declaration

public static ISubscribable<TSource> Throttle<TSource, TThrottle>(this ISubscribable<TSource> source, Func<TSource, ISubscribable<TThrottle>> throttleSelector)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to throttle.
System.Func<TSource, ISubscribable<TThrottle>>	throttleSelector	Selector function to obtain throttling duration sequences for source elements.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence with the throttled elements from the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.
TThrottle	Type of the elements in the throttling sequences.

Throw<TResult>(Exception)

Returns an observable sequence that produces an OnError notification with the specified error.

Declaration

public static ISubscribable<TResult> Throw<TResult>(Exception error)

Parameters

Type	Name	Description
System.Exception	error	Error to propagate in the resulting sequence.

Returns

Type	Description
ISubscribable<TResult>	An observable sequence that propagates the specified error.

Type Parameters

Name	Description
TResult	Type of the elements in the resulting sequence.

Timer(DateTimeOffset)

Returns an observable sequence that generates an element at the specified absolute due time.

Declaration

public static ISubscribable<long> Timer(DateTimeOffset dueTime)

Parameters

Type	Name	Description
System.DateTimeOffset	dueTime	Absolute time when the timer is due.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence producing a single element at the specified absolute due time.

Timer(DateTimeOffset, TimeSpan)

Returns an observable sequence that generates elements for each timer tick specified by the absolute due time and period.

Declaration

public static ISubscribable<long> Timer(DateTimeOffset dueTime, TimeSpan period)

Parameters

Type	Name	Description
System.DateTimeOffset	dueTime	Absolute time when the first timer tick is due.
System.TimeSpan	period	Period of the timer.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence producing an element for each tick of the timer conform the specified absolute due time and period.

Exceptions

Type	Condition
System.ArgumentOutOfRangeException	Thrown when the period is less than zero.

Timer(TimeSpan)

Returns an observable sequence that generates an element at the specified relative due time.

Declaration

public static ISubscribable<long> Timer(TimeSpan dueTime)

Parameters

Type	Name	Description
System.TimeSpan	dueTime	Time when the timer is due. This time is relative to the time of subscription.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence producing a single element at the specified relative due time.

Timer(TimeSpan, TimeSpan)

Returns an observable sequence that generates elements for each timer tick specified by the relative due time and period.

Declaration

public static ISubscribable<long> Timer(TimeSpan dueTime, TimeSpan period)

Parameters

Type	Name	Description
System.TimeSpan	dueTime	Time when the first timer tick is due. This time is relative to the time of subscription.
System.TimeSpan	period	Period of the timer.

Returns

Type	Description
ISubscribable<System.Int64>	Observable sequence producing an element for each tick of the timer conform the specified relative due time and period.

Exceptions

Type	Condition
System.ArgumentOutOfRangeException	Thrown when the period is less than zero.

ToList<TSource>(ISubscribable<TSource>)

Aggregates the source sequence into a list containing all of its elements.

Declaration

public static ISubscribable<IList<TSource>> ToList<TSource>(this ISubscribable<TSource> source)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to aggregate into a list.

Returns

Type	Description
ISubscribable<System.Collections.Generic.IList<TSource>>	Observable sequence containing a single element with a list containing all of the elements in the sequence. If the source sequence is empty, an empty list is returned.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

ToSubscribable<TSource>(IObservable<TSource>)

Converts an observable sequence to a subscribable sequence.

Declaration

public static ISubscribable<TSource> ToSubscribable<TSource>(IObservable<TSource> source)

Parameters

Type	Name	Description
System.IObservable<TSource>	source	Observable sequence to convert to a subscribable sequence.

Returns

Type	Description
ISubscribable<TSource>	Subscribable sequence producing the same notifications as the specified observable sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Where<TSource>(ISubscribable<TSource>, Func<TSource, Boolean>)

Filters elements from the source sequence using the specified predicate function.

Declaration

public static ISubscribable<TSource> Where<TSource>(this ISubscribable<TSource> source, Func<TSource, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to filter.
System.Func<TSource, System.Boolean>	predicate	Predicate function used to determine whether an element should be included in the result sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the elements from the source sequence that match the predicate.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Where<TSource>(ISubscribable<TSource>, Func<TSource, Int32, Boolean>)

Filters elements from the source sequence using the specified predicate function that takes in an element index.

Declaration

public static ISubscribable<TSource> Where<TSource>(this ISubscribable<TSource> source, Func<TSource, int, bool> predicate)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence whose elements to filter.
System.Func<TSource, System.Int32, System.Boolean>	predicate	Predicate function used to determine whether an element should be included in the result sequence.

Returns

Type	Description
ISubscribable<TSource>	Observable sequence containing the elements from the source sequence that match the predicate.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Window<TSource>(ISubscribable<TSource>, Int32)

Partitions the source sequence into windows based on the specified window length.

Declaration

public static ISubscribable<ISubscribable<TSource>> Window<TSource>(this ISubscribable<TSource> source, int count)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate windows for.
System.Int32	count	Number of elements per window.

Returns

Type	Description
ISubscribable<ISubscribable<TSource>>	Observable sequence containing windows of the specified length over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Window<TSource>(ISubscribable<TSource>, Int32, Int32)

Partitions the source sequence into windows based on the specified window length and element skip count.

Declaration

public static ISubscribable<ISubscribable<TSource>> Window<TSource>(this ISubscribable<TSource> source, int count, int skip)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate windows for.
System.Int32	count	Number of elements per window.
System.Int32	skip	Offset of the number of elements between the start of one window and the next.

Returns

Type	Description
ISubscribable<ISubscribable<TSource>>	Observable sequence containing windows of the specified length over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Window<TSource>(ISubscribable<TSource>, TimeSpan)

Partitions the source sequence into windows based on the specified window duration.

Declaration

public static ISubscribable<ISubscribable<TSource>> Window<TSource>(this ISubscribable<TSource> source, TimeSpan duration)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate windows for.
System.TimeSpan	duration	Duration of a window.

Returns

Type	Description
ISubscribable<ISubscribable<TSource>>	Observable sequence containing windows of the specified duration over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Window<TSource>(ISubscribable<TSource>, TimeSpan, Int32)

Partitions the source sequence into windows that are closed when they're full or a given amount of time has elapsed. A useful real-world analogy of this overload is the behavior of a ferry leaving the dock when all seats are taken, or at the scheduled time of departure, whichever event occurs first.

Declaration

public static ISubscribable<ISubscribable<TSource>> Window<TSource>(this ISubscribable<TSource> source, TimeSpan duration, int count)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate windows for.
System.TimeSpan	duration	Maximum duration of a window.
System.Int32	count	Maximum number of elements per window.

Returns

Type	Description
ISubscribable<ISubscribable<TSource>>	Observable sequence containing windows over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.

Window<TSource>(ISubscribable<TSource>, TimeSpan, TimeSpan)

Partitions the source sequence into windows based on the specified window duration and time shift.

Declaration

public static ISubscribable<ISubscribable<TSource>> Window<TSource>(this ISubscribable<TSource> source, TimeSpan duration, TimeSpan shift)

Parameters

Type	Name	Description
ISubscribable<TSource>	source	Source sequence to generate windows for.
System.TimeSpan	duration	Duration of a window.
System.TimeSpan	shift	Time shift between one window and the next.

Returns

Type	Description
ISubscribable<ISubscribable<TSource>>	Observable sequence containing windows of the specified duration over the source sequence.

Type Parameters

Name	Description
TSource	Type of the elements in the source sequence.