RxSwift) Creating Operators (repeatElement, deferred, create)

repeatElement

let disposeBag = DisposeBag()
let element = "👍"

Observable.repeatElement(element)
    .take(10)
    .subscribe { print($0) }
    .disposed(by: disposeBag)

출력

next(👍)
next(👍)
next(👍)
next(👍)
next(👍)
next(👍)
next(👍)
next(👍)
next(👍)
next(👍)
completed

동일한 요소를 반복적으로 방출하는 연산자입니다.

무한정 반복합니다.

따라서 방출되는 횟수를 정해주는게 중요합니다. take 연산자를 사용해서 10개의 요소만 방출되도록 해주었습니다.

deferred

let disposeBag = DisposeBag()
var flag = true

let observable : Observable<Int> = Observable.deferred {
    flag.toggle()
    if flag {
        return Observable.just(1)
    } else {
        return Observable.just(2)
    }
}

observable
    .subscribe { print($0) }
    .disposed(by: disposeBag)

출력

next(2)
completed

특정조건에 따라 옵저버블을 생성하는 연산자 입니다. flag 조건에 따라 2가 들어간 just옵저버블이 구독된것을 확인할 수 있습니다.

create

just, of, from, range, genarate, repeatElement, deferred 등의 연산자는 옵저버블에 받은 요소를 방출하고 completed를 통해서 완료됩니다

이런 동작 방식을 바꾸기 위해선 create를 통해서 새로운 옵저버블을 만들 필요가 있습니다.

create는 Observer을 파라미터로 받아서 Disposable을 리턴합니다.

return에 유의 해야 합니다. Disposable을 리턴하라고 되어있는데 컴파일 에러가 발생합니다. 꼭 Disposables.create() 로 리턴해줍니다.

create옵저버블을 통해 요소를 방출할때는 onNext메소드를 사용해야 합니다.

create옵저버블을 종료하기 위해선 onError, onCompleted 중 하나를 꼭 호출해야합니다.

let disposeBag = DisposeBag()

enum MyError: Error {
   case error
}

Observable<String>.create { (observer) -> Disposable in
    observer.onNext("내가 하고싶은 처리")
    observer.onCompleted()
    return Disposables.create()
}
.subscribe{ print($0) }
.disposed(by: disposeBag)

출력

next(내가 하고싶은 처리)
completed

웹에서 html 문자열을 받는 옵저버블 생성

Observable.create { (observer) -> Disposable in
    guard let url = URL(string: "<https://huniroom.tistory.com/>") else {
        observer.onError(MyError.error)
        return Disposables.create()
    }
    
    guard let html = try? String(contentsOf: url, encoding: .utf8) else {
        observer.onError(MyError.error)
        return Disposables.create()
    }
    observer.onNext(html)
    observer.onCompleted()
    
    return Disposables.create()
}
.subscribe{ print($0) }
.disposed(by: disposeBag)