Skip to content

Commit 426e252

Browse files
Tried to improve type inference, alas.
1 parent 1ea162d commit 426e252

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observer.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -71,10 +71,10 @@ object Observer {
7171

7272
}
7373

74-
def apply[T]( ): Observer[T] = apply(v=>{}, e=>{}, ()=>{})
75-
def apply[T](onNext: T=>Unit ): Observer[T] = apply(onNext, e=>{}, ()=>{})
76-
def apply[T](onNext: T=>Unit, onError: Throwable=>Unit ): Observer[T] = apply(onNext, onError, ()=>{})
77-
def apply[T](onNext: T=>Unit, onCompleted: ()=>Unit): Observer[T] = apply(onNext, e=>{}, onCompleted)
74+
def apply[T]( ): Observer[T] = apply[T]((v:T)=>(), (e: Throwable)=>(), ()=>())
75+
def apply[T](onNext: T=>Unit ): Observer[T] = apply[T](onNext, (e: Throwable)=>(), ()=>())
76+
def apply[T](onNext: T=>Unit, onError: Throwable=>Unit ): Observer[T] = apply[T](onNext, onError, ()=>())
77+
def apply[T](onNext: T=>Unit, onCompleted: ()=>Unit): Observer[T] = apply[T](onNext, (e: Throwable)=>(), onCompleted)
7878
def apply[T](n: T=>Unit, e: Throwable=>Unit, c: ()=>Unit): Observer[T] = {
7979
// Java calls XXX; Scala receives XXX.
8080
Observer(new rx.Observer[T]{

language-adaptors/rxjava-scala/src/test/scala/rx/lang/scala/SubjectTests.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@ class SubjectTest extends JUnitSuite {
1818

1919
@Test def PublishSubjectIsAChannel() {
2020

21+
val zzz = Observer[Integer]()
22+
2123
var lastA: Integer = null
2224
var errorA: Throwable = null
2325
var completedA: Boolean = false

0 commit comments

Comments
 (0)