Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package example
- import monix.execution.Ack
- object scala {
- def main(args: Array[String]): Unit = {
- implicit val s = monix.execution.schedulers.TestScheduler()
- val parent = monix.reactive.subjects.PublishSubject[Int]()
- val child = monix.reactive.subjects.PublishSubject[Int]()
- val o = parent.switchMap(x => child.map(x -> _))
- o.subscribe{ u =>
- print(u)
- Ack.Continue
- }
- parent.onNext(1)
- child.onNext(1)
- parent.onComplete()
- child.onNext(2)
- // prints "(1, 1)" - in RxScala, this would print "(1,1)(1,2)"
- }
- }
Add Comment
Please, Sign In to add comment