Create RxObservable with defer

RxObservableDefer.swift

func createRxObservable() {
    let source: Observable<Int>  = Observable.deferred {
        let source: Observable<Int> = Observable.create { observer in
            for i in 1...5 {
                observer.on(.next(i))
            }
            observer.on(.completed)
            return Disposables.create()
        }
        return source
    }
    
    source
        .subscribe(onNext: { number in
            print("Current emitted number: ", number)
        }, onError: nil,
           onCompleted: {
            print("Complete")
        }, onDisposed: nil)
}