Qbservable.GroupByUntil<TSource, TKey, TElement, TDuration> (IQbservable TSource>, Expression<Func TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<<IGroupedObservable<TKey, TElement>, IObservable<<TDuration>>>, IEqualityComparer<TKey>)
Agrupa los elementos de una secuencia observable consultable según una función y comparador de selector de claves especificada y selecciona los elementos resultantes mediante una función especificada.
Espacio de nombres:System.Reactive.Linq
Ensamblaje: System.Reactive.Providers (en System.Reactive.Providers.dll)
Sintaxis
'Declaration
<ExtensionAttribute> _
Public Shared Function GroupByUntil(Of TSource, TKey, TElement, TDuration) ( _
source As IQbservable(Of TSource), _
keySelector As Expression(Of Func(Of TSource, TKey)), _
elementSelector As Expression(Of Func(Of TSource, TElement)), _
durationSelector As Expression(Of Func(Of IGroupedObservable(Of TKey, TElement), IObservable(Of TDuration))), _
comparer As IEqualityComparer(Of TKey) _
) As IQbservable(Of IGroupedObservable(Of TKey, TElement))
'Usage
Dim source As IQbservable(Of TSource)
Dim keySelector As Expression(Of Func(Of TSource, TKey))
Dim elementSelector As Expression(Of Func(Of TSource, TElement))
Dim durationSelector As Expression(Of Func(Of IGroupedObservable(Of TKey, TElement), IObservable(Of TDuration)))
Dim comparer As IEqualityComparer(Of TKey)
Dim returnValue As IQbservable(Of IGroupedObservable(Of TKey, TElement))
returnValue = source.GroupByUntil(keySelector, _
elementSelector, durationSelector, _
comparer)
public static IQbservable<IGroupedObservable<TKey, TElement>> GroupByUntil<TSource, TKey, TElement, TDuration>(
this IQbservable<TSource> source,
Expression<Func<TSource, TKey>> keySelector,
Expression<Func<TSource, TElement>> elementSelector,
Expression<Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>> durationSelector,
IEqualityComparer<TKey> comparer
)
[ExtensionAttribute]
public:
generic<typename TSource, typename TKey, typename TElement, typename TDuration>
static IQbservable<IGroupedObservable<TKey, TElement>^>^ GroupByUntil(
IQbservable<TSource>^ source,
Expression<Func<TSource, TKey>^>^ keySelector,
Expression<Func<TSource, TElement>^>^ elementSelector,
Expression<Func<IGroupedObservable<TKey, TElement>^, IObservable<TDuration>^>^>^ durationSelector,
IEqualityComparer<TKey>^ comparer
)
static member GroupByUntil :
source:IQbservable<'TSource> *
keySelector:Expression<Func<'TSource, 'TKey>> *
elementSelector:Expression<Func<'TSource, 'TElement>> *
durationSelector:Expression<Func<IGroupedObservable<'TKey, 'TElement>, IObservable<'TDuration>>> *
comparer:IEqualityComparer<'TKey> -> IQbservable<IGroupedObservable<'TKey, 'TElement>>
JScript does not support generic types and methods.
Parámetros de tipo
- TSource
Origen del tipo.
- TKey
Clave de tipo.
- TElement
Elemento type.
- TDuration
Duración del tipo.
Parámetros
- source
Tipo: System.Reactive.Linq.IQbservable<TSource>
Secuencia observable consultable cuyos elementos se van a agrupar.
- keySelector
Tipo: System.Linq.Expressions.Expression<Func<TSource, TKey>>
Función para extraer la clave de cada elemento.
- elementSelector
Tipo: System.Linq.Expressions.Expression<Func<TSource, TElement>>
Función para asignar cada elemento de origen a un elemento de un grupo observable.
- durationSelector
Tipo: System.Linq.Expressions.Expression<Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>>
Función para indicar la expiración de un grupo.
- comparer
Tipo: System.Collections.Generic.IEqualityComparer<TKey>
Comparador de igualdad con el que se comparan las claves.
Valor devuelto
Tipo: System.Reactive.Linq.IQbservable<IGroupedObservable<TKey, TElement>>
Secuencia de grupos observables consultables, cada uno de los cuales corresponde a un valor de clave único, que contiene todos los elementos que comparten ese mismo valor de clave.
Nota sobre el uso
En Visual Basic y C#, puede llamar a este método como método de instancia en cualquier objeto de tipo IQbservable<TSource>. Cuando emplee la sintaxis del método de instancia para llamar a este método, omita el primer parámetro. Para obtener más información, vea o .