174. (swift5/xcode) [RxSwift] [Observable] flatMap 사용해 Observable 사용해 이벤트 받아서, 해당 인덱스 별 새로운 아이템 발행

---

[개발 환경 설정]

​

개발 툴 : XCODE

개발 언어 : SWIFT5

​

 

---

[소스 코드]

​

 

    // -----------------------------------------------------------------------------------------
    // MARK: - [테스트 메인 함수 정의 실시]
    // -----------------------------------------------------------------------------------------
    func testMain() {
        S_Log._D_(description: "테스트 함수 시작 실시", data: nil)
        
        
        /*
         ------------------------------------
         [요약 설명]
         ------------------------------------
         1. 반응형 프로그래밍 은 데이터의 흐름을 먼저 정의하고, 데이터가 변경되었을 때 [연관된 작업] 을 수행합니다
         ------------------------------------
         2. ReactiveX 는 Observer Pattern 옵저버 패턴 을 확장하며, Sequence 를 조합할 수 있는 연산자를 지원하며,
         low-level Thread, 동기화, Thread 안전성, non-blocking I/O에 관한 우려를 줄입니다
         ------------------------------------
         3. 필요 import :
         
         import RxSwift
         ------------------------------------
         4. 라이브러리 설치 참고 사이트 :
         
         https://blog.naver.com/kkh0977/223268744402
         https://github.com/ReactiveX/RxSwift
         ------------------------------------
         */
        
        
        // [로직 처리 실시]
        DispatchQueue.main.async {
            
            // [변수 선언]
            let first = Observable.of(1, 2)
            let second = Observable.of("하나", "둘")
            
            
            // [flatMap : Observable 사용해 이벤트 받아서, 해당 인덱스 별 새로운 Observable 발행 수행]
            let subscrive = first.flatMap { (x: Int) -> Observable<String> in
                S_Log._D_(description: "observable :: first", data: ["\(x)"])
                return second
            }.subscribe(
                onNext: { element in // [발행 아이템 요소]
                    
                    S_Log._D_(description: "observable :: second :: onNext", data: ["\(element)"])
                    
                }) { onError in // [발행 에러]
                    
                    S_Log._D_(description: "observable :: second :: onError", data: ["\(onError)"])
                    
                } onCompleted: { // [발행 완료]
                    
                    S_Log._D_(description: "observable :: second :: onCompleted", data: nil)
                    
                } onDisposed: { // [구독 연결 및 해제]
                    
                    S_Log._D_(description: "observable :: second :: onDisposed", data: nil)
                    
                }
            
        }

    }

 

---

[결과 출력]

​

 

 

---