// 建立了一个空内容的 Observable let ob = Observable<Int>.empty() // 先简单的写一种订阅的方法 ob.subscribe { print("执行了") }
// 这里不用给定泛型,会根据 just 自动推倒出 let ob = Observable.just("初始化默认值")
let ob = Observable.of("可", "变", "数", "量")
let ob = Observable.from(["数", "组"])
let ob = Observable<Any>.never()
enum OBError: Error { case abc } let ob = Observable<OBError>.error(OBError.abc)
let ob = Observable<Int>.interval(1, scheduler: MainScheduler.asyncInstance)
// 3 秒后,仅发送一次 let ob = Observable<Int>.timer(3, scheduler: MainScheduler.instance) // 3 秒后,每 2 秒发送一次 let ob = Observable<Int>.timer(3, period: 2, scheduler: MainScheduler.asyncInstance)
搬迁自本人简书数组