IObservable<int> sourceNumbers = System.Reactive.Linq.Observable.Range(1, 25);

sourceNumbers.GroupBy(number => number % 3).Subscribe(
    group =>
    {
        Console.WriteLine($"New group:{group.Key}");
    });