У меня есть Наблюдаемая с именем myObservable
, и моя цель - вызвать onComplete
, для самого первого излучаемого элемента, ИЛИ , когда пусто.
Итак Я делаю это:
myObservable.firstElement().ignoreElement().subscribe {
// OnComplete is called.
}
Итак, я преобразую его в Maybe, используя firstElement()
, затем преобразую это Maybe в Completable, используя ignoreElement()
. Я хочу, чтобы onComplete
вызывался либо когда Возможно звонит onSuccess
, либо onComplete
.
Это правильный путь?