We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 67449fb commit 866d0b3Copy full SHA for 866d0b3
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/package.scala
@@ -104,6 +104,13 @@ package object scala {
104
def unsubscribe() = s.unsubscribe()
105
}
106
107
+ private[scala] implicit def schedulerActionToFunc2[T](action: (Scheduler, T) => Subscription) =
108
+ new rx.util.functions.Func2[rx.Scheduler, T, rx.Subscription] {
109
+ def call(s: rx.Scheduler, t: T): rx.Subscription = {
110
+ action(ImplicitFunctionConversions.javaSchedulerToScalaScheduler(s), t)
111
+ }
112
113
+
114
private[scala] implicit def fakeObserver2RxObserver[T](o: Observer[T]): rx.Observer[_ >: T] = ???
115
private[scala] implicit def rxObserver2fakeObserver[T](o: rx.Observer[_ >: T]): Observer[T] = ???
116
0 commit comments