一些经常在测试中使用到的Observable
-
1s
- observer.onNext("First -> 1|A")
- observer.onNext("First -> 1|B")
- observer.onNext("First -> 1|C")
-
5s
- observer.onNext("First -> 2|A")
- observer.onNext("First -> 2|B")
- observer.onNext("First -> 2|C")
-
9s
- observer.onNext("First -> 3|A")
- observer.onNext("First -> 3|B")
- observer.onNext("First -> 3|C")
- observer.onCompleted()
func getFirstObservable() -> Observable<String> {
return Observable<String>.create({ (observer) -> Disposable in
// section 1
delayTime(1, block: {
observer.onNext("First -> 1|A")
observer.onNext("First -> 1|B")
observer.onNext("First -> 1|C")
})
// section 2
delayTime(5, block: {
observer.onNext("First -> 2|A")
observer.onNext("First -> 2|B")
observer.onNext("First -> 2|C")
})
// section 3
delayTime(9, block: {
observer.onNext("First -> 3|A")
observer.onNext("First -> 3|B")
observer.onNext("First -> 3|C")
observer.onCompleted()
})
return Disposables.create()
})
}
-
0.1s
- observer.onNext("Second -> 1")
-
4.1s
- observer.onNext("Second -> 2")
-
8.1s
- observer.onNext("Second -> 3")
- observer.onCompleted()
func getSecondObservable() -> Observable<String> {
return Observable<String>.create({ (observer) -> Disposable in
delayTime(0.1, block: {
observer.onNext("Second -> 1")
delayTime(4, block: {
observer.onNext("Second -> 2")
})
delayTime(8, block: {
observer.onNext("Second -> 3")
observer.onCompleted()
})
})
return Disposables.create()
})
}
- 0.1s
- observer.onNext("Third -> 1")
- observer.onNext("Third -> 2")
- observer.onNext("Third -> 3")
- observer.onCompleted()
func getThirdObservable() -> Observable<String> {
return Observable<String>.create({ (observer) -> Disposable in
delayTime(0.1, block: {
observer.onNext("Third -> 1")
observer.onNext("Third -> 2")
observer.onNext("Third -> 3")
observer.onCompleted()
})
return Disposables.create()
})
}
-
0s
- print("> Send onNext("0️⃣")")
- observer.onNext("0️⃣")
-
1s
- print("> Send onNext("1️⃣")")
- observer.onNext("1️⃣")
-
2s
- print("> Send onNext("2️⃣")")
- observer.onNext("2️⃣")
func getFourthObservable() -> Observable<String> {
let observable = Observable<String>.create({ (observer) -> Disposable in
print("> Send onNext(\"0️⃣\")")
observer.onNext("0️⃣")
delayTime(1, block: {
print("> Send onNext(\"1️⃣\")")
observer.onNext("1️⃣")
})
delayTime(2, block: {
print("> Send onNext(\"2️⃣\")")
observer.onNext("2️⃣")
})
return Disposables.create()
})
return observable
}
-
1s
- observer.onNext("1️⃣")
-
2s
- observer.onNext("2️⃣")
-
3s
- let err = TError.init(errorCode: 10, errorString: "Test", errorData: nil)
- observer.onError(err)
func getErrorObservable() -> Observable<String> {
return Observable<String>.create({ (observer) -> Disposable in
delayTime(1, block: {
observer.onNext("1️⃣")
})
delayTime(2, block: {
observer.onNext("2️⃣")
})
delayTime(3, block: {
let err = TError.init(errorCode: 10, errorString: "Test", errorData: nil)
observer.onError(err)
})
return Disposables.create()
})
}