NoSuchMethodError: rx.functions.Actions.onErrorFrom(Lrx/Observer;)

[ayedo]

The following code throws a:

java.lang.NoSuchMethodError: rx.functions.Actions.onErrorFrom(Lrx/Observer;)Lrx/functions/Action1;

What went wrong?

import rx.lang.scala.ImplicitFunctionConversions._
import rx.lang.scala.JavaConversions._

def sendIndexFromThread(s: Subject[Int], repeats: Int) = new Thread(new Runnable {
    def run() {
      var i = 0
      while (i < repeats) {
        s.onNext(i)
        i = i + 1
      }
      s.onCompleted()
    }
})

val internalSize = 1024

val s1 = Subject[Int]
val s2 = Subject[Int]

val o1 = s1.onBackpressureBuffer.observeOn(NewThreadScheduler())
val o2 = s2.onBackpressureBuffer.observeOn(NewThreadScheduler())

val gotAll = new CountDownLatch(internalSize * 2)
val latch = new CountDownLatch(1)
val counter = new AtomicInteger(0)

val p1 = JoinObservable.from(o1).then((x: Int) => {
  counter.incrementAndGet()
  if (counter.get == (internalSize * 2)) { latch.countDown }
})
val p2 = JoinObservable.from(o2).then((x: Int) => {
  counter.incrementAndGet()
  if (counter.get == (internalSize * 2)) { latch.countDown }
})

val obs = JoinObservable.when(p1, p2).toObservable

obs.subscribe((_: Unit) => gotAll.countDown, (_: Throwable) => (), () => ())

val thread1 = sendIndexFromThread(s1, internalSize)
val thread2 = sendIndexFromThread(s2, internalSize)

thread1.start()
thread2.start()

latch.await
gotAll.await

thread1.join()
thread2.join()

[ayedo]

Is the problem above related to: this RxJava issue?

[akarnokd]

RxJava had some utility class changes which broke other depending projects. This should be fixed now and expect a new release in a few hours on maven central.