关于创建Observable

#1 Create

image

您可以使用create操作符从零开始创建一个可观察对象，传递给这个操作符一个函数，该函数接受observer作为其参数，通过适当地调用observer的onNext、onError和onCompleted方法，将这个函数编写为一个可观察的函数。
需要注意的是一个结构良好的Observable必须调用一次observer的onCompleted或onError方法，并且此后不能尝试调用observer的任何其他方法。

let source : Observable = Observable.create { observer in
    for i in 1...5 {
        observer.on(.next(i))
    }
    observer.on(.completed)
    return Disposables.create {
        print("disposed")
    }
}

source.subscribe {
    print($0)
}
/*-----
next(1)
next(2)
next(3)
next(4)
next(5)
completed
disposed
*/ 

#2 Empty/Never

Empty

image

创建一个不发出任何项但正常终止的Observable(调用onCompleted)

Never
创建一个不发出任何项且不终止的可观察对象

image

Empty/Never这些对于测试目的很有用，有时也可以与其他可观测值结合使用，或者作为期望其他可观测值作为参数的操作符的参数。

let never = Observable<Any>.never()
    
let empty = Observable<Any>.empty()
    
    
never.subscribe { (event) in
    print("never")
    print(event)
}
.disposed(by: bag)
    
empty.subscribe { (event) in
    print("empty")
    print(event)
}
.disposed(by: bag)

/*------
empty
completed
*/ 

#3 From

image

作用将各种其他对象和数据类型转换为可观察的

let anyArray : [Any] = ["string", 1 , 0.3]

let source = Observable.from(anyArray)

source.subscribe {
    print($0)
}

/*----------
next(string)
next(1)
next(0.3)
completed
*/ 

#4 Interval

创建一个Observable，它发出一个按给定时间间隔间隔的整数序列
Interval操作符返回一个可观察到的值，该值发出一个无限的升序整数序列，在两次发射之间选择一个固定的时间间隔。

image

Observable<Int>.interval(1.0, scheduler: MainScheduler.instance)
    .subscribe {
        print($0)
    }
    .disposed(by: bag)
//每1秒发送一次从0开始升序的整数

#5 Just

创建一个发出特定值的Observable
与From类型，但要注意From会将数组里的元素取出再发送出去，而Just只是简单的将数组或对象作为一个单独值发送出去。

image

let source = Observable.just(1, 2, 3)

source.subscribe {
    print($0)
}

let source2 = Observable.just([1,2,3])

source2.subscribe {
    print($0)
}
/* ------
next((1, 2, 3))
completed
next([1, 2, 3])
completed
*/ 

#6 Range

创建一个Observable，该对象发出特定范围的序列整数

image

Observable.range(start: 1, count: 3)
    .subscribe{
        print($0)
    }
    .disposed(by: bag)
    
/*------
next(1)
next(2)
next(3)
completed
*/ 

#7 Repeat

创建一个Observable，该对象多次发出特定的项

image

该操作符重复发送一个项。

#8 Timer

创建一个Observable，它在给定的延迟之后发出特定的项

image

//5秒后发送一个Int值
Observable<Int>.timer(5, scheduler: MainScheduler.instance)
    .subscribe {
        print($0)
    }
    .disposed(by: bag)
/*-------
next(0)
completed
*/

#9 Of

此方法创建一个Observable，该实例具有可变数量的元素。
功能与From相同，From接受数组为元素，Of接受可变数量的元素

let ofObservable = Observable<Any>.of(1,"test",0.3)

ofObservable.subscribe{
    print($0)
}
.disposed(by: bag)

/*-------------
next(1)
next(test)
next(0.3)
completed
*/

文章出处