static IObservable<IGroupedObservable<TKey, TSource>> GroupBy<TSource, TKey>(
  this IObservable<TSource> source,
  Func<TSource, TKey> keySelector)
{
    return new GroupByOperator<TSource, TKey>(source, keySelector);
}