Я новичок в Rx и в довольно сложной ситуации для новичка ie.
У меня есть ситуация, когда я вызываю функцию, чтобы сказать doSomething. В doSomething я делаю вызов API под названием apiCall. Этот API возвращает один. Я на самом деле не хочу использовать этот единственный результат. Вызов API вызывает механизм, который отправляет наблюдаемый поток строк (эта наблюдаемая возвращается fnCallreturnsAnObservableStreamOfString), и мне нужно вернуть это из забавного doSomething
В настоящее время я использую flatMapObservable, это Компилируется нормально, но не работает правильно.
override fun doSomething(firstParam: Int, secondParam: Int) : Observable<String> =
apiCall(firstParam,secondParam).flatMapObservable{ fnCallreturnsAnObservableStreamOfString()}
Может кто-нибудь, пожалуйста, помогите мне сделать это правильно.
Редактировать: -
Проблема с кодом заключается в вызове doSomething fnCallreturnsAnObservableStreamOfString () не вызывается.