Add SplitByTypes observables

src/main/scala-3/com/raquo/airstream/split/MatchSplitObservable.scala

@@ -0,0 +1,35 @@
+package com.raquo.airstream.split
+
+import com.raquo.airstream.core.{Observable, BaseObservable}
+import scala.annotation.compileTimeOnly
+
+/**
+ * `MatchSplitObservable` served as macro's data holder for macro expansion.
+ *
+ * For example:
+ *
+ * ```scala
+ * fooSignal.splitMatch
+ *  .handleCase { case Bar(Some(str)) => str } { (str, strSignal) => renderStrNode(str, strSignal) }
+ *    .handleCase { case baz: Baz => baz } { (baz, bazSignal) => renderBazNode(baz, bazSignal) }
+ * ```
+ *
+ * will be expanded sematically into:
+ *
+ * ```scala
+ *  MatchSplitObservable.build(fooSignal, ({ case baz: Baz => baz }) :: ({ case Bar(Some(str)) => str }) :: Nil, handlerMap)
+ * ```
+ */
+
+opaque type MatchSplitObservable[Self[+_] <: Observable[_] , I, O] = Unit
+
+object MatchSplitObservable {
+
+  @compileTimeOnly("splitMatch without toSignal/toStream is illegal")
+  def build[Self[+_] <: Observable[_] , I, O](
+    observable: BaseObservable[Self, I],
+    caseList: List[PartialFunction[Any, Any]],
+    handlerMap: Map[Int, Function2[Any, Any, O]]
+  ): MatchSplitObservable[Self, I, O] = throw new UnsupportedOperationException("splitMatch without toSignal/toStream is illegal")
+
+}

src/main/scala-3/com/raquo/airstream/split/MatchTypeObservable.scala

@@ -0,0 +1,52 @@
+package com.raquo.airstream.split
+
+import com.raquo.airstream.core.{Observable, BaseObservable}
+import scala.annotation.compileTimeOnly
+
+/** `MatchTypeObservable` served as macro's data holder for macro expansion.
+ *
+ * For example:
+ *
+ * ```scala
+ * fooSignal.splitMatch
+ *   .splitType[Baz] { (baz, bazSignal) => renderBazNode(baz, bazSignal) }
+ * ```
+ *
+ * will be expanded sematically into:
+ *
+ * ```scala
+ * MatchTypeObservable.build[*, *, *, Baz](
+ *   fooSignal,
+ *   Nil,
+ *   handlerMap,
+ *   ({ case t: Baz => t })
+ * )
+ * ```
+ *
+ * and then into:
+ *
+ * ```scala
+ * MatchSplitObservable.build(
+ *   fooSignal,
+ *   ({ case baz: Baz => baz }) :: Nil,
+ *   handlerMap
+ * )
+ * ```
+ */
+
+opaque type MatchTypeObservable[Self[+_] <: Observable[_], I, O, T] = Unit
+
+object MatchTypeObservable {
+
+  @compileTimeOnly("splitMatch without toSignal/toStream is illegal")
+  def build[Self[+_] <: Observable[_], I, O, T](
+      observable: BaseObservable[Self, I],
+      caseList: List[PartialFunction[Any, Any]],
+      handlerMap: Map[Int, Function2[Any, Any, O]],
+      tCast: PartialFunction[T, T]
+  ): MatchTypeObservable[Self, I, O, T] =
+    throw new UnsupportedOperationException(
+      "splitMatch without toSignal/toStream is illegal"
+    )
+
+}

src/main/scala-3/com/raquo/airstream/split/MatchValueObservable.scala

@@ -0,0 +1,52 @@
+package com.raquo.airstream.split
+
+import com.raquo.airstream.core.{Observable, BaseObservable}
+import scala.annotation.compileTimeOnly
+
+/** `MatchSingletonObservable` served as macro's data holder for macro expansion.
+ *
+ * For example:
+ *
+ * ```scala
+ * fooSignal.splitMatch
+ *   .splitValue(Tar)(tarSignal => renderTarNode(tarSignal))
+ * ```
+ * 
+ * will be expanded sematically into:
+ *
+ * ```scala
+ * MatchTypeObservable.build[*, *, *, Baz](
+ *   fooSignal,
+ *   Nil,
+ *   handlerMap,
+ *   ({ case Tar => Tar })
+ * )
+ * ```
+ *
+ * and then into:
+ *
+ * ```scala
+ * MatchSplitObservable.build(
+ *   fooSignal,
+ *   ({ case Tar => Tar }) :: Nil,
+ *   handlerMap
+ * )
+ * ```
+ */
+
+opaque type MatchValueObservable[Self[+_] <: Observable[_], I, O, V0, V1] = Unit
+
+object MatchValueObservable {
+
+  @compileTimeOnly("splitMatch without toSignal/toStream is illegal")
+  def build[Self[+_] <: Observable[_], I, O, V0, V1](
+      observable: BaseObservable[Self, I],
+      caseList: List[PartialFunction[Any, Any]],
+      handlerMap: Map[Int, Function2[Any, Any, O]],
+      vCast: PartialFunction[V0, V1]
+  ): MatchValueObservable[Self, I, O, V0, V1] =
+    throw new UnsupportedOperationException(
+      "splitMatch without toSignal/toStream is illegal"
+    )
+
+}