Can't find Observable.compose(), any alternatives?

[samuelgruetter]

There's a guide which should answer all questions of this kind. compose was intentionally left out because it is considered non-Scala-idiomatic. As the guide suggests, I'd use extension methods.

[grant-guo]

@samuelgruetter Thanks! you mean I have to use implicit class to wrap a rxjava Observable inside?

[samuelgruetter]

Yes, but I'd wrap the RxScala Observable inside the implicit class, not the RxJava Observable.

[dhoepelman]

I personally find compose much clearer, as a workaround, it's not difficult to add compose yourself as an extension method:

implicit class ObservableCompose[T](val obs: Observable[T]) extends AnyVal {
  def compose[U](transformer: Observable[T] => Observable[U]): Observable[U] = f(obs)
}

[dhoepelman]

Due to project EOL status, no new operators will be added.