swift RxSwift：Observables

Posted 2021-05-19

// Of
// Create an observable with a single values
Observable<Int>.of(1, 2, 3)
    .subscribe(onNext: {
        print("Of: \($0)")
    })
    .disposed(by: disposeBag)

// From
// Create an observable from a collection
Observable<Int>.from([0,1,2,3,4,5,6])
    .subscribe(onNext: {
        print("From: \($0)")
    })
    .disposed(by: disposeBag)

// Interval
// Trigger next at n seconds interval
Observable<Int>.interval(1.0, scheduler: MainScheduler.instance)
    .subscribe(onNext: {
        print("Interval: \($0)")
    })
    .disposed(by: disposeBag)

// Timer
// Wait n seconds then trigger next ???
Observable<Int>.timer(5, scheduler: MainScheduler.instance)
    .subscribe(onNext: {
        print("Timer: \($0)")
    })
    .disposed(by: disposeBag)