let empty return Observable[Nothing]/Rx[Nothing]

cornerman · Nov 20, 2023 · 17f3ff3 · 17f3ff3
1 parent 6f87959
commit 17f3ff3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/colibri/src/main/scala/colibri/Observable.scala b/colibri/src/main/scala/colibri/Observable.scala
@@ -89,8 +89,8 @@ object Observable    {
     @inline def unsafeSubscribe(sink: Observer[Nothing]): Cancelable = Cancelable.empty
   }
 
-  @inline def empty[A]: Observable[A] = Empty
-  val unit: Observable[Unit]          = Observable.pure(())
+  @inline def empty: Observable[Nothing] = Empty
+  val unit: Observable[Unit]             = Observable.pure(())
 
   def pure[T](value: T): Observable[T] = new Observable[T] {
     def unsafeSubscribe(sink: Observer[T]): Cancelable = {

diff --git a/reactive/src/main/scala/colibri/reactive/Reactive.scala b/reactive/src/main/scala/colibri/reactive/Reactive.scala
@@ -112,7 +112,7 @@ trait RxEvent[+A] extends RxSource[A] with RxSourceSelf[RxEvent, RxEvent, A] {
 
 object RxEvent extends RxPlatform {
   private val _empty: RxEvent[Nothing] = observableUnshared(Observable.empty)
-  @inline def empty[A]: RxEvent[A]     = _empty
+  @inline def empty: RxEvent[Nothing]  = _empty
 
   @inline def apply[A](values: A*): RxEvent[A] = iterable(values)
 
@@ -148,7 +148,7 @@ trait RxLater[+A] extends RxState[A] with RxSourceSelf[RxLater, RxLater, A] {
 }
 
 object RxLater {
-  @inline def empty[A]: RxLater[A] = RxLaterEmpty
+  @inline def empty: RxLater[Nothing] = RxLaterEmpty
 
   def future[A](future: => Future[A]): RxLater[A]          = observable(Observable.fromFuture(future))
   def effect[F[_]: RunEffect, A](effect: F[A]): RxLater[A] = observable(Observable.fromEffect(effect))