Observable.GroupBy<TSource, TKey, TElement> – metoda (IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)
Seskupí prvky pozorovatelné sekvence a vybere výsledné prvky pomocí zadané funkce.
Obor názvů:System.Reactive.Linq
Sestavení: System.Reactive (v System.Reactive.dll)
Syntax
'Declaration
<ExtensionAttribute> _
Public Shared Function GroupBy(Of TSource, TKey, TElement) ( _
source As IObservable(Of TSource), _
keySelector As Func(Of TSource, TKey), _
elementSelector As Func(Of TSource, TElement) _
) As IObservable(Of IGroupedObservable(Of TKey, TElement))
'Usage
Dim source As IObservable(Of TSource)
Dim keySelector As Func(Of TSource, TKey)
Dim elementSelector As Func(Of TSource, TElement)
Dim returnValue As IObservable(Of IGroupedObservable(Of TKey, TElement))
returnValue = source.GroupBy(keySelector, _
elementSelector)
public static IObservable<IGroupedObservable<TKey, TElement>> GroupBy<TSource, TKey, TElement>(
this IObservable<TSource> source,
Func<TSource, TKey> keySelector,
Func<TSource, TElement> elementSelector
)
[ExtensionAttribute]
public:
generic<typename TSource, typename TKey, typename TElement>
static IObservable<IGroupedObservable<TKey, TElement>^>^ GroupBy(
IObservable<TSource>^ source,
Func<TSource, TKey>^ keySelector,
Func<TSource, TElement>^ elementSelector
)
static member GroupBy :
source:IObservable<'TSource> *
keySelector:Func<'TSource, 'TKey> *
elementSelector:Func<'TSource, 'TElement> -> IObservable<IGroupedObservable<'TKey, 'TElement>>
JScript does not support generic types and methods.
Parametry typu
- Tsource
Zdroj typu.
- Tkey
Klávesa typu.
- Telement
Element type.
Parametry
- source
Typ: System.IObservable<TSource>
Pozorovatelná sekvence, jejíž prvky se mají seskupit.
- keySelector
Typ: System.Func<TSource, TKey>
Funkce, která extrahuje klíč pro každý prvek.
- elementSelector
Typ: System.Func<TSource, TElement>
Funkce mapuje každý zdrojový prvek na prvek v pozorovatelné skupině.
Návratová hodnota
Typ: System.IObservable<IGroupedObservable<TKey, TElement>>
Posloupnost pozorovatelných skupin, z nichž každá odpovídá jedinečné hodnotě klíče obsahující všechny prvky, které sdílejí stejnou hodnotu klíče.
Poznámka k využití
V jazyce Visual Basic a C# můžete tuto metodu volat jako metodu instance u libovolného objektu typu IObservable<TSource>. Pokud k volání této metody použijete syntaxi metody instance, vynechejte první parametr. Další informace naleznete v tématech a .
Poznámky
Operátor GroupBy slouží k seskupení zdrojové sekvence položek do skupin na základě hodnoty klíče. Každá hodnota klíče je výsledkem funkce keySelector a může být odvozena od každé položky ve zdrojové sekvenci. Výsledkem operátoru GroupBy je posloupnost seskupených položek reprezentovaných posloupností IGroupedObservable<TKey, TElement>. IGroupedObservable zveřejňuje vlastnost klíče, která identifikuje seskupenou sekvenci. Skutečné položky ve výsledných seskupených sekvencích jsou řízeny výsledkem funkce elementSelector použité u každé zdrojové položky.
Příklady
Tento ukázkový kód vygeneruje posloupnost záznamů protokolu událostí, ke kterým došlo během posledních šesti hodin. Operátor GroupBy se pak použije s příkazem LINQ k seskupení záznamů událostí, které jsou chyby založené na vlastnosti LevelDisplayName, která se vyhodnocuje na "Error" nebo "Critical". Pokud je to pravda, výsledek funkce výběru klíčů je true, což vede k seskupení záznamu události ve skupině chyb. Výsledkem operátoru GroupBy je IGroupedObservable<logická hodnota EventRecord>. Tato sekvence IGroupedObservable je přihlášena k odběru přístupu k položkám seskupených chybových událostí. Kód prozkoumá sekvenci skupin a najde skupinu, ve které je hodnota klíče true. Hodnota klíče true identifikuje skupinu chyb. Tato skupina chyb se pak přihlásí k odběru a položky protokolu událostí chyb se zapíšou do okna konzoly.
using System;
using System.Reactive.Linq;
using System.Reactive.Concurrency;
using System.Diagnostics.Eventing.Reader;
using System.IO;
namespace Example
{
class Program
{
static void Main()
{
//************************************************************************************************//
//*** Generate a sequence of event log entries that have been written to the system event log ***//
//*** within the last 6 hours. ***//
//************************************************************************************************//
const int eventLogTimeSpan = 6;
EventLogReader sysEventLog = new EventLogReader("System");
//****************************************************************************************************//
//*** Start with the last entry in the event log. ***//
//*** Stop on an event generated at a time more than the EventLogTimeSpan (6 hrs in this example). ***//
//*** Each iteration function will step back one entry. ***//
//*** The resultSelector function will just select each entry for inclusion in the sequence. ***//
//*** The ThreadPool schedule schedules the processing of the event log on a thread pool thread ***//
//****************************************************************************************************//
sysEventLog.Seek(SeekOrigin.End,0);
EventRecord lastEntry = sysEventLog.ReadEvent();
var eventLogEntrySeq = Observable.Generate(lastEntry,
x => (DateTime.Now - x.TimeCreated) < TimeSpan.FromHours(eventLogTimeSpan),
x => {sysEventLog.Seek(x.Bookmark,-1); return sysEventLog.ReadEvent();},
x => x,
Scheduler.ThreadPool);
//************************************************************************************************************//
//*** Use the GroupBy operator with LINQ to group the sequence into entries that are errors (key=true) and ***//
//*** those that are not errors (key=false). ***//
//************************************************************************************************************//
var eventLogGroupedSeq =
from entry in eventLogEntrySeq
group entry by (entry.LevelDisplayName == "Error") || (entry.LevelDisplayName == "Critical") into groupedEntries
select groupedEntries;
//***************************************************************************************//
//*** eventLogGroupedSeq is a IGroupedObservable<Boolean, EventRecord>. Subscribing ***//
//*** will return a sequence of the groups. For this example, we only want the group ***//
//*** where the key is true indicating the Error entries group. So we then subscribe ***//
//*** to that grouped sequence to write the error entries that occurred within the ***//
//*** last 6 hours. ***//
//***************************************************************************************//
eventLogGroupedSeq.Subscribe(groupedSeq =>
{
if (groupedSeq.Key == true)
{
groupedSeq.Subscribe(evtEntry => Console.WriteLine("ID : {0}\n" +
"Type : {1}\n" +
"Source: {2}\n" +
"Time Generated: {3}\n" +
"Message: {4}\n",
evtEntry.Id,
evtEntry.LevelDisplayName,
evtEntry.ProviderName,
evtEntry.TimeCreated.ToString(),
evtEntry.FormatDescription()));
}
});
Console.WriteLine("\nDisplaying error entries from the system event log\n" +
"that occurred within the last {0} hours...\n\n" +
"Press ENTER to exit...\n",eventLogTimeSpan);
Console.ReadLine();
}
}
}
Následující výstup byl vygenerován s ukázkovým kódem.
Displaying error entries from the system event log
that occurred within the last 6 hours...
Press ENTER to exit...
ID : 34001
Type : Error
Source: Microsoft-Windows-SharedAccess_NAT
Time Generated: 5/31/2011 4:39:18 AM
Message: The ICS_IPV6 failed to configure IPv6 stack.
ID : 34001
Type : Error
Source: Microsoft-Windows-SharedAccess_NAT
Time Generated: 5/31/2011 4:01:36 AM
Message: The ICS_IPV6 failed to configure IPv6 stack.
ID : 34001
Type : Error
Source: Microsoft-Windows-SharedAccess_NAT
Time Generated: 5/31/2011 3:49:29 AM
Message: The ICS_IPV6 failed to configure IPv6 stack.
ID : 34001
Type : Error
Source: Microsoft-Windows-SharedAccess_NAT
Time Generated: 5/31/2011 3:11:47 AM
Message: The ICS_IPV6 failed to configure IPv6 stack.
ID : 34001
Type : Error
Source: Microsoft-Windows-SharedAccess_NAT
Time Generated: 5/31/2011 2:59:40 AM
Message: The ICS_IPV6 failed to configure IPv6 stack.