Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import Foundation
- import RxSwift
- let bag = DisposeBag()
- let test: Observable<Void> = Observable.create { (observer) -> Disposable in
- //observer.onNext(())
- observer.onCompleted()
- return AnonymousDisposable { }
- }
- let test2: Observable<String> = Observable.create { (observer) -> Disposable in
- observer.onNext("test")
- observer.onCompleted()
- return AnonymousDisposable { }
- }
- Observable.combineLatest(test, test2) { (voidObj, stringObj) -> String in
- return stringObj
- }.subscribeNext { (string) in
- print(string)
- }.addDisposableTo(bag)
- //test.concat(test2)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement