Qbservable.GroupByUntil<TSource, TKey, TElement, TDuration> Method (IQbservable<TSource>, Expression<Func TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>>)
Grupuje elementy możliwej do obserwacji sekwencji zapytań zgodnie z określoną funkcją selektora kluczy i wybiera wynikowe elementy przy użyciu określonej funkcji.
Przestrzeń nazw:System.Reactive.Linq
Zestawu: System.Reactive.Providers (w System.Reactive.Providers.dll)
Składnia
'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))) _
) 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 returnValue As IQbservable(Of IGroupedObservable(Of TKey, TElement))
returnValue = source.GroupByUntil(keySelector, _
elementSelector, durationSelector)
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
)
[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
)
static member GroupByUntil :
source:IQbservable<'TSource> *
keySelector:Expression<Func<'TSource, 'TKey>> *
elementSelector:Expression<Func<'TSource, 'TElement>> *
durationSelector:Expression<Func<IGroupedObservable<'TKey, 'TElement>, IObservable<'TDuration>>> -> IQbservable<IGroupedObservable<'TKey, 'TElement>>
JScript does not support generic types and methods.
Parametry typu
- Tsource
Źródło typu.
- Tkey
Klucz typu.
- Telement
Element type.
- Data trwania
Czas trwania typu.
Parametry
- source
Typ: System.Reactive.Linq.IQbservable<TSource>
Obserwowana sekwencja z możliwością wykonywania zapytań, której elementy do grupowania.
- keySelector
Typ: System.Linq.Expressions.Expression<Func<TSource, TKey>>
Funkcja wyodrębniania klucza do każdego elementu.
- elementSelector
Typ: System.Linq.Expressions.Expression<Func<TSource, TElement>>
Funkcja mapowania każdego elementu źródłowego na element w obserwowalnej grupie.
- durationSelector
Typ: System.Linq.Expressions.Expression<Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>>
Funkcja sygnalizowania wygaśnięcia grupy.
Wartość zwracana
Typ: System.Reactive.Linq.IQbservable<IGroupedObservable<TKey, TElement>>
Sekwencja obserwowanych grup, z których każda odpowiada unikatowej wartości klucza, zawierająca wszystkie elementy współużytkujące tę samą wartość klucza.
Uwaga dotycząca użycia
W języku Visual Basic i C# można wywołać tę metodę jako metodę wystąpienia dla dowolnego obiektu typu IQbservable<TSource>. Gdy w celu wywołania tej metody jest używana składnia metody wystąpienia, należy pominąć pierwszy parametr. Aby uzyskać więcej informacji, zobacz lub .