Create RxObservable with repeat

RxObservableRepeat.swift

func createRxObservable() {
    let source: Observable<Int> = Observable.repeatElement(12).take(2)
    
    source
        .subscribe(onNext: { number in
            print("Current emitted number: ", number)
        }, onError: { _ in print("On Error") },
           onCompleted: { print("Complete") },
           onDisposed: nil)
}