Added aliases and objects for concrete subject types in Scala. #485
Conversation
-AsyncSubject[T] -BehaviorSubject[T] -PublishSubject[T] -ReplaySubject[T]
|
RxJava-pull-requests #410 SUCCESS |
|
This is not really helping as subjects are “unrelated” to rx.lang.scala.Observable. At this point I believe we need to give up on transparent interop from Scala to Java. I am finishing up a binding that feels more native Scala, and is very close to what I catually promise in my slides. Object Observable {…} def asJavaObservable: rx.Observable[_ <: T] } object Observer {…} trait Observer[-T] { def asJavaObserver: rx.Observer[_ >: T] } object Subject {…} trait Subject[-T, +R] extends Observable[R] with Observer[T] { val asJavaSubject: rx.subjects.Subject[_ >: T, _<: R] } object Scheduler {…} trait Scheduler { def asJavaScheduler: rx.Scheduler; } object Notification {…} trait Notification[+T] { def asJavaNotification: rx.Notification[_ <: T] } object Subscription {…} trait Subscription { def asJavaSubscription: rx.Subscription } From: Rob Emanuele [mailto:[email protected]] -AsyncSubject[T] You can merge this Pull Request by running git pull https://github.com/lossyrob/RxJava subjects Or view, comment on, or merge it at: Commit Summary
File Changes
Patch Links: |
|
Fair. I wanted to use PublishSubjects idiomatically from Scala, and wrapping them was in the TODO list, but if something better is in the pipeline then that's great. Is there a link to the slides you mention? |
-AsyncSubject[T]
-BehaviorSubject[T]
-PublishSubject[T]
-ReplaySubject[T]