I tried the below:
import rx.lang.scala.Observable
Observable.from(Seq(1,2)).zipWith(Observable.from(Seq(3,4)))
When I show the resulting type I see:
((Int, Int) => Nothing) => Observable[Nothing]
I'm trying to get into an Observable[Int, Int] , what did I do wrong?
Observable[Int, Int]doesn't make sense:Observableonly has a single type parameter. If you wantObservable[(Int, Int)], you needzip.zipWithrequires another argument: a function which tells you how to combine elements.