Слияние кода завершено, страница обновится автоматически
Операторы могут связывать несколько Observable в один сигнал Observable.
startWith
Отправляет указанный элемент, который вставляется перед элементами в очереди. Подробнее.
example("startWith") {
let disposeBag = DisposeBag()
Observable.of("🐶", "🐱", "🐭", "🐹")
.startWith("1️⃣")
.startWith("2️⃣")
.startWith("3️⃣", "🅰️", "🅱️")
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
}
Как показано в примере,
startWidthможет быть объединён в очередь FIFO (первым пришёл — первым вышел), и все элементы, унаследованные отStartWidth, добавляются перед элементамиStartWidth.
merge
Объединяет элементы из нескольких источников Observable в одну очередь сигналов Observable, и отправляет события исходной очереди Observable. Подробнее.
example("merge") {
let disposeBag = DisposeBag()
let subject1 = PublishSubject<String>()
let subject2 = PublishSubject<String>()
Observable.of(subject1, subject2)
.merge()
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
subject1.onNext("🅰️")
subject1.onNext("🅱️")
subject2.onNext("①")
subject2.onNext("②")
subject1.onNext("🆎")
subject2.onNext("③")
}
zip
Связывает до восьми источников очередей Observable в источник сигнала, и отправляет элементы, соответствующие исходным номерам очередей, пока каждый исходный номер очереди имеет элемент. Подробнее.
example("zip") {
let disposeBag = DisposeBag()
let stringSubject = PublishSubject<String>()
let intSubject = PublishSubject<Int>()
Observable.zip(stringSubject, intSubject) { stringElement, intElement in
"\(stringElement) \(intElement)"
}
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
stringSubject.onNext("🅰️")
stringSubject.onNext("🅱️")
intSubject.onNext(1)
intSubject.onNext(2)
stringSubject.onNext("🆎")
intSubject.onNext(3)
}
combineLatest
Связывает максимум восемь очередей Observable для создания новой очереди сигналов, и связывает каждый последний элемент исходной очереди в новый элемент сигнала. Каждый раз, когда в исходную очередь добавляется элемент, отправляется новый связанный элемент.
Подробнее.
example("combineLatest") {
let disposeBag = DisposeBag()
let stringSubject = PublishSubject<String>()
let intSubject = PublishSubject<Int>()
Observable.combineLatest(stringSubject, intSubject) { stringElement, intElement in
"\(stringElement) \(intElement)"
}
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
stringSubject.onNext("🅰️")
stringSubject.onNext("🅱️")
intSubject.onNext(1)
intSubject.onNext(2)
stringSubject.onNext("🆎")
}
Существует также расширение combineLatest для массива:
example("Array.combineLatest") {
let disposeBag = DisposeBag()
let stringObservable = Observable.just("❤️")
let fruitObservable = Observable.from(["🍎", "🍐", "🍊"])
let animalObservable = Observable.of("🐶", "🐱", "🐭", "🐹")
Observable.combineLatest([stringObservable, fruitObservable, animalObservable]) {
"\($0[0]) \($0[1]) \($0[2])"
}
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
}
Расширение массива требует, чтобы элементы исходного массива были одного типа. Элементы добавляются в массив по порядку 111222333....
switchLatest
Преобразует элементы, отправленные очередью Observable, и отправляет последнее значение внутренней очереди. Подробнее.
example("switchLatest") {
let disposeBag = DisposeBag()
let subject1 = BehaviorSubject(value: "⚽️")
let subject2 = BehaviorSubject(value: "🍎")
let variable = Variable(subject1)
``` ```
variable.asObservable()
.switchLatest()
.subscribe(onNext: { print($0) })
.addDisposableTo(disposeBag)
subject1.onNext("🏈")
subject1.onNext("🏀")
variable.value = subject2
subject1.onNext("⚾️")
subject2.onNext("🍐")
В этом примере установка
variable.value=subject2и последующее добавление элемента «⚾️» вsubject1не будет иметь никакого эффекта, так как только последний внутреннийObservableочередиsubject2будет отправлять элементы.
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Опубликовать ( 0 )