Hi! If I have some non-trivial observable chain l...

# rx

[dimsuz]

Hi!

If I have some non-trivial observable chain like

fun createObservable(): Observable<Data> {
   return someFactory.observe()
      .flatMap { someOp(it) }
      .flatMap { someOp(it) }
}

Now I want the following: if some client code subscribes to the returned observable and it starts executing, but then client code unsubscribes, before say the first flatMap will be executed (example: in Android user went back from the screen and subscription was disposed) - how to ensure that the whole rx chain continues execution until it terminates with either success or error?

Am I right that this will need to somehow involve a ConnectableObservable?