Create RxObservable with create

RxObservableCreate.swift

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