Swift Combine에서 Reduce 연산자 활용하기

Swift Combine은 비동기적인 데이터 흐름을 처리하고 조합하기 위한 강력한 도구입니다. Combine 프레임워크에서 제공하는 Reduce 연산자들 중에는 collect, reduce, tryReduce, ignoreOutput 등이 있습니다. 이번 글에서는 각각의 연산자의 개념과 사용 예제를 알아보고, 실제로 어떻게 활용할 수 있는지 살펴보겠습니다.

 

collect 연산자 collect 연산자는 Publisher가 방출하는 값들을 지정된 컬렉션 형태로 수집하는 역할을 합니다. 이를 통해 여러 값들을 한 번에 수집하거나 조합하여 처리할 수 있습니다.

import Combine

let numbers = (1...5).publisher

numbers
    .collect()
    .sink { values in
        print("Collected: \(values)")
    }

위의 예제에서는 numbers라는 Publisher를 생성하고, 이를 통해 1부터 5까지의 숫자를 방출합니다. 그리고 Collect 연산자를 사용하여 방출된 모든 값을 배열로 수집합니다. 이후, 수집된 값들을 출력하는 Sink 연산자를 통해 결과를 확인합니다.

 

reduce 연산자 reduce 연산자는 Publisher가 방출하는 값을 조합하여 단일 결과값을 생성하는 역할을 합니다. 이를 통해 여러 값들을 축약하여 최종 결과를 얻을 수 있습니다.

 

import Combine

let numbers = (1...5).publisher

numbers
    .reduce(0) { accumulator, value in
        return accumulator + value
    }
    .sink { result in
        print("Reduced: \(result)")
    }

위의 예제에서는 numbers라는 Publisher를 생성하고, 이를 통해 1부터 5까지의 숫자를 방출합니다. 그리고 Reduce 연산자를 사용하여 모든 값을 더하여 최종 결과를 생성합니다. 이후, 최종 결과를 출력하는 Sink 연산자를 통해 결과를 확인합니다.

 

tryReduce 연산자 tryReduce 연산자는 reduce 연산자와 동일한 기능을 제공하지만, 에러 처리를 지원합니다. 에러가 발생하면 Publisher가 완료되고 에러를 전달하며, 에러가 발생하지 않으면 정상적인 결과를 생성합니다.

import Combine

enum MyError: Error {
    case example
}

let numbers = [1, 2, 3, 4, 5].publisher

numbers
    .tryReduce(0) { accumulator, value in
        guard value != 3 else {
            throw MyError.example
        }
        return accumulator + value
    }
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("Completed without errors.")
        case .failure(let error):
            print("Error occurred: \(error)")
        }
    }, receiveValue: { result in
        print("Reduced: \(result)")
    })

위의 예제에서는 배열 [1, 2, 3, 4, 5]를 Publisher로 생성하고, TryReduce 연산자를 사용하여 값을 더하되, 값이 3인 경우 에러를 발생시킵니다. 이후, 에러 발생 여부에 따라 에러 처리 또는 정상적인 결과를 출력합니다.

 

ignoreOutput 연산자 ignoreOutput 연산자는 Publisher가 방출하는 값을 무시하고, 완료만을 전달하는 역할을 합니다. 주로 상태 변화나 완료 여부에만 관심이 있는 경우에 사용됩니다.

 

import Combine

let numbers = (1...5).publisher

numbers
    .ignoreOutput()
    .sink(receiveCompletion: { completion in
        switch completion {
        case .finished:
            print("Completed without output.")
        case .failure(let error):
            print("Error occurred: \(error)")
        }
    }, receiveValue: { value in
        // 이 블록은 실행되지 않음
    })

위의 예제에서는 numbers라는 Publisher를 생성하고, IgnoreOutput 연산자를 사용하여 방출되는 값을 무시합니다. 이후, 완료 여부에 따라 완료 메시지를 출력합니다.

 

위의 예제들은 각 Reduce 연산자를 사용하여 Publisher에서 방출되는 값을 조합하거나 처리하는 방법을 보여줍니다. Combine 프레임워크의 다양한 연산자와 조합하여 더 복잡한 데이터 흐름 처리도 가능합니다.

이 글에서는 Swift Combine에서 Reduce 연산자들의 개념과 사용 예제에 대해 알아보았습니다. Reduce 연산자들을 활용하면 Publisher에서 방출되는 값들을 조합하여 원하는 결과를 얻을 수 있습니다. Swift Combine을 활용하여 데이터 흐름을 효과적으로 처리하고 조합하는 방법을 익혀보세요.