public interface IGroupedObservable<out TKey, out TSource> : IObservable<TSource>
{
    // Gets the common key.
    TKey Key { get; }
}