Require user defined conversion for multicast

bonsai-rx · Jul 6, 2023 · 54ffac5 · 54ffac5
1 parent 7dcd6af
commit 54ffac5
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/Bonsai.Core/Expressions/MulticastSubject.cs b/Bonsai.Core/Expressions/MulticastSubject.cs
@@ -60,6 +60,13 @@ public override Expression Build(IEnumerable<Expression> arguments)
             var subjectType = subjectExpression.Type.GetGenericArguments()[0];
             if (observableType != subjectType)
             {
+                if (!HasConversion(observableType, subjectType))
+                {
+                    throw new InvalidOperationException(
+                        $"No coercion operator is defined between types '{observableType}' and '{subjectType}'."
+                    );
+                }
+
                 source = CoerceMethodArgument(typeof(IObservable<>).MakeGenericType(subjectType), source);
                 observableType = subjectType;
             }