Ensure all created group observables are hot

SainsburyWellcomeCentre · Oct 16, 2024 · e101212 · e101212
1 parent f4ed4e4
commit e101212
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/Aeon.Acquisition/CreateGroup.cs b/src/Aeon.Acquisition/CreateGroup.cs
@@ -86,8 +86,13 @@ class GroupedObservable<TKey, TElement> : IGroupedObservable<TKey, TElement>
         {
             public GroupedObservable(TKey key, IObservable<TElement> source)
             {
+                if (source is null)
+                {
+                    throw new ArgumentNullException(nameof(source));
+                }
+
                 Key = key;
-                Source = source ?? throw new ArgumentNullException(nameof(source));
+                Source = source.Publish().RefCount();
             }
 
             public TKey Key { get; }