Combine(1): Publisher, Subscriber!

 

 

GRAIN 은 Combine 해야됩니다! 라고 당당하게 외쳤으니 가보자고 ~~ ! !

스유의 꽃 ! 🌸  Combine 에 대해 공부했던 부분을 공유하려고 해요!

지금부터 Combine 세미나 1탄 시작합니당 👏🏻

흠.. 그럼 먼저 컴바인이 도대체 멀까!? 찍먹부터 해볼까요 ?

그래그래 그래서 컴바인이 무엇인고..! 해보니

 

https://developer.apple.com/documentation/combine

Combine | Apple Developer Documentation

 

The Combine framework provides a declarative Swift API for processing values over time. These values can represent many kinds of asynchronous events.

 

 

해석해보면, 컴바인은 일단 framework 이고,

시간에 따른 값을 처리하기 위한 Swift API를 제공한다고 합니다.

이러한 값들은 많은 종류의 비동기 이벤트를 나타낼수 있다고 하네요!

 

why combine?

흠 오키 ! 근데.. 그래서 .. 왜! Combine이 필요한가? 라고 느끼실 수 있는데요

기존의 Swift 언어의 단점 중 하나는 비동기 처리가 굉장히,,,, 뭐 같았습니다 ! ㅎㅎ

 

기존의 비동기처리방식에는 DispatchQueue에 접근하거나, completionHandler를 전달받아 해당 작업이 완료되었을때 호출하는 방식을 사용했었는데, 결론적으로 비동기처리 코드가 넘나 복잡했다 이거죠!

 

그래서 컴바인을 사용해 이벤트 처리 코드와 중첩 클로져나 콜백함수 와 같은 까다로운(지저분쓰한) 기술을 제거함으로써 코드를 유지보수하기 편하게 만들어 주려고 애플이 신기술을 내놓은거죠.

 

이것만 봐서는 감이 안오실텐데요! Combine은 백문이 불여일타 입니다.

쳐보기 전에는 이게 뭐지 ? 쉽게 감이 안잡히더라구요.

 

 

Combine Overview

먼저 Combine에서 가장 중요한 Publisher와 Subscriber 개념들을 알아볼거에요!

1. Publisher: 생산자 라고 생각하면 될것같아요!
2. Subscriber: 구독자 라고 생각하면 될것같아요!

먼저 Publisher와 Subscriber 의 관계부터 설명드리자면,

Publisher 와 Subscriber의 관계는 유튜브 크리에이터와 구독자로 비유할수 있습니다.

구독자는 크리에이터를 구독을 해야지만 해당 크리에이터가 영상을 받아서 볼수 있죠

이 개념이랑 똑같습니다!

Publisher(크리에이터) 가 데이터(영상)를 가공(Operator)해서 배출하면 Subscriber(구독자) 가 그 데이터를 받는거죠

 

 

Publisher ?

그럼 Publisher 개념에 대해 알아볼게요

Apple Developer Documentation

Publisher | Apple Developer Documentation

public protocol Publisher<Output, Failure> {
    associatedtype Output
    associatedtype Failure : Error

    func receive<S>(subscriber: S) where S : Subscriber, Self.Failure == S.Failure, Self.Output == S.Input
}

먼저 쉽게 말하면 Publisher는 데이터를 배출 💩 하는 친구입니다.

Publisher protocol을 살펴보면

• Output 과 Failure (에러 타입) 을 정의합니다.
• Subscriber 가 요청한 것 만큼 데이터를 제공합니다.

 

 

Subscriber ?

Subscriber 개념에 대해 알아볼게요

Subscriber | Apple Developer Documentation

Subscriber | Apple Developer Documentation

public protocol Subscriber<Input, Failure> : CustomCombineIdentifierConvertible {
    associatedtype Input
    associatedtype Failure : Error

    func receive(subscription: Subscription)
    func receive(_ input: Self.Input) -> Subscribers.Demand
    func receive(completion: Subscribers.Completion<Self.Failure>)
}

Subscriber 는 Publisher에게 데이터를 요청하는 칭구입니다.

Publisher protocol을 살펴보면

• Input과 Failture(에러타입) 타입을 정의해야합니다.
• Publisher 구독후 , 갯수를 요청합니다.
• 파이프라인을 취소할 수 있습니다.

 

 

Subscriber & Publisher Pattern

그럼 빌트인 Publisher와 Subscriber 종류와 사용방법에 대해 알아볼게요!

먼저 Publisher에는 Just 와 Future 라는 빌트인 Publisher가 존재합니다.

• Just: 단일 값을 다루는 Publisher 입니다.
• Future: 아직 발생하지 않은 단일 값을 비동기적으로 방출하는, Function을 다루는 Publisher입니다.

Subscriber 에는 assign 과 sink 가 존재합니다 .

• assign: Subscriber의 값을 특정 객체의 프로퍼티에 할당하는데 사용합니다.
• sink: Publisher가 제공한 데이터를 받을 수 있는 클로져를 제공합니다.

그럼 한번 사용해볼게요!

• Publisher

// Just (Publisher)

let justPublisher = Just("hello wonder")

let subscription = justPublisher.sink { value in
    print(value) // "hello wonder"
}

// Future (Publisher)
func performAsyncTask() -> Future<String, Error> {
    return Future<String, Error> { promise in
        // 비동기 작업 수행
        // 작업이 완료되면 결과를 promise에 방출
        if success {
            promise(.success("작업 수행 완료"))
        } else {
            promise(.failure(SomeError))
        }
    }
}

let futurePublisher = performAsyncTask()

let subscription = futurePublisher.sink { completion in
    switch completion {
    case .finished:
        print("작업 수행 완료")
    case .failure(let error):
        print("오류 발생: \\(error)")
    }
} receiveValue: { value in
    print(value) 
}

 

• Subscriber

import Combine

// assign (Subscriber) 
class ViewModel {
    @Published var count: Int = 0 // UI 요소에 바인딩할 프로퍼티 
}

let viewModel = ViewModel()
let publisher = Just(100)

// assign 메서드는 특정 KeyPath 를 사용하여 값을 할당합니다. 
let subscription = publisher.assign(to: \.count, on: viewModel)

print(viewModel.count) // 100


// sink (Subscriber)
let publisher = Just("hello wonder")

let subscription = publisher.sink { value in
    print(value) // "hello wonder"
}

 

 

Subscription?

Subscription | Apple Developer Documentation

Subscription | Apple Developer Documentation

이 Subscription이 무엇이냐! Publisher(유튜버) 가 Subscriber(구독자) 에게

구독을 했으니 내 영상을 이제 보여줄게! 라고 인증해주는 인증서 이라고 보시면 됩니다.

즉 Subscriber 와 Publisher가 연결이 되었음을 나타내는 친구이죠.

 

이 Subscription 의 정의를 보면 ,

Cancellable 프로토콜을 따르고 있는거 보이시나요?

이 Cancellable 프로토콜은 구독을 취소할 수 있는 타입을 나타내는 프로토콜입니다.

• Cancellable 프로토콜을 채택한 타입은 cancel() 메서드를 구현해서 구독을 취소할 수 있습니다.

 

그럼 cancel() 메서드를 사용하는 이유는 무엇일까요 ?

바로 메모리 누수를 방지하고 불필요한 리소스 낭비를 막기 위해서겠죠!!!

 

일시적인 구독이나 현재 필요하지 않은 구독을 계속 유지하게 되면 앱의 성능에도 영향을 줄 수 있어요!

따라서 구독이 더이상 필요하지 않을때는 cancel() 메서드를 호출해서 구독을 취소하고, 리소스를 해제하는 것이 좋습니다.

(일반적으로 deinit 메서드나, 앱에서 더이상 구독이 필요하지 않는 타이밍에 구독을 취소할 수 있습니다. )

var cancellable: AnyCancellable?

cancellable = publisher
    .sink { value in
        // 값 처리
    }

// 구독 취소
cancellable?.cancel()

SwiftUI 코드 로도 한번 적용시켜 볼게요!

import Combine
import SwiftUI 

class ViewModel: ObservableObject {
    @Published var count: Int = 0
    private var cancellables = Set<AnyCancellable>()
    
    func setupSubscriptions() {
        $count
            .sink { value in
                print("New count: \\(value)")
            }
            .store(in: &cancellables) // cancel 될 수 있는 구독들을 저장합니다. 
    }
    
    deinit {
        cancellables.forEach { $0.cancel() } // 인스턴스 메모리에서 해체될때 호출 
    }
}

struct ContentView: View {
    @StateObject private var viewModel = ViewModel()
    
    var body: some View {
        VStack {
            Text("Count: \\(viewModel.count)")
            Button("Increment") {
                viewModel.count += 1
            }
        }
        .onAppear {
            viewModel.setupSubscriptions()
        }
    }
}

 

코드로 보니까 더 이해가 가는것 같지 않나요??? ㅎㅎㅎㅎ

 

 

 

여기까지 Publisher와 Subscriber의 개념과 기본적인 사용법? 을 알아봤습니다 😆

또 Publisher 와 Subscriber의 연결을 나타내는 개체인 Subscription 도 한번 알아봤습니다! 😁

 

다음 타자는 바로 Subject 입니다 두둥 그럼 다음 시간에 만나용

아뇨뇽 ~~~🍎 🤍

 

 

참고

• 패스트 캠퍼스 왕초보를 위한, 한 번에 끝내는 iOS 앱 개발 바이블