последовательности: одна конечная, другая бесконечная, чтобы при завершении конечной последовательности заканчивалась и результирующая?
Привет, могу рассказать из мира RxJava, но я думаю принцип тот же, у тебя 2 последовательности возвращают один тип данных или разный?
тут вариантов много, как и ситуаций. Но прям готового инструмента для выбора момента onComplete при объединении нету. Все эти мержи ждут onComplete от всех последовательностей, а не от одной. Если тебе обязательно нужно по событию onComplete делать, то выход один: Создаешь Subject и в него скидываешь события: let subject = PublishSubject<Void>() finiteObservable.subscribe { (event) in self.subject.on(event) }.disposed(by: bag) infiniteObservable.subscribe { (event) in switch event { case let .next(elem): self.subject.onNext(elem) default: break } }.disposed(by: bag) subject.subscribe { (event) in // Your code }.disposed(by: bag)
Обсуждают сегодня