File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -3,16 +3,16 @@ package rx.lang.scala
3
3
trait Subscriber [- T ] extends Observer [T ] with Subscription {
4
4
5
5
self =>
6
-
7
- private [scala] override val asJavaObserver : rx.Observer [_ >: T ] = asJavaSubscriber
8
- private [scala] override val asJavaSubscription : rx.Subscription = asJavaSubscriber
9
-
6
+
10
7
private [scala] val asJavaSubscriber : rx.Subscriber [_ >: T ] = new rx.Subscriber [T ] {
11
8
def onNext (value : T ): Unit = self.onNext(value)
12
9
def onError (error : Throwable ): Unit = self.onError(error)
13
10
def onCompleted (): Unit = self.onCompleted()
14
11
}
15
-
12
+
13
+ private [scala] override val asJavaObserver : rx.Observer [_ >: T ] = asJavaSubscriber
14
+ private [scala] override val asJavaSubscription : rx.Subscription = asJavaSubscriber
15
+
16
16
/**
17
17
* Used to register an unsubscribe callback.
18
18
*/
You can’t perform that action at this time.
0 commit comments