ReactiveX#238: Initial commit to implement Single and Completable in …

…RxScala1
Proximator · Jul 23, 2018 · 25611d9 · 25611d9
1 parent d063641
commit 25611d9
Show file tree

Hide file tree

Showing 4 changed files with 1,020 additions and 0 deletions.
diff --git a/src/main/scala/rx/lang/scala/JavaConversions.scala b/src/main/scala/rx/lang/scala/JavaConversions.scala
@@ -55,6 +55,12 @@ object JavaConversions {
     }
   }
 
+  implicit def toScalaSingle[T](single: rx.Single[_ <: T]): Single[T] = {
+    new Single[T]{
+      val asJavaSingle = single
+    }
+  }
+
   implicit def toJavaOperator[T, R](operator: Subscriber[R] => Subscriber[T]): rx.Observable.Operator[R, T] = {
     new rx.Observable.Operator[R, T] {
       override def call(subscriber: rx.Subscriber[_ >: R]): rx.Subscriber[_ >: T] = {