기본 개념

Publisher

• Rx의 Observable과 같은 개념
• Publisher<데이터타입, 에러타입>
  • 에러타입 중 [Never] → 에러타입 내보내지 않음

💡 AnyPublisher VS Observable

⭐️ Publisher

• Value Type

struct AnyPublisher: Publisher { 
	... 
}

• 값과 오류가 어떻게 생성되는지 미리 정의를 한다. output과 failure를 associatedType으로 가지고 있다.
  • Output(Data Type)
  • Failure(Error Type)
• AnyPublisher<String, Error>
• AnyPublisher<String, Never>

⭐️ Observable

• Reference Type

class Observable: ObservableType { 
	... 
}

• element라는 데이터 타입만 받는다. 그러나 Result타입을 사용하면 Publisher와 비슷하게 사용 가능하다.
  • Element(Data Type)
  • ❌
• Observable<Result<String, Error>>
• Observable<String>

💡 Combine Operators

⭐️ map

func map<T>(_ transform: (Output) -> T) -> Just<T>

⭐️ tryMap

func tryMap<T>(_ transform: (Output) throws -> T) -> Result<T, Error>.publisher

이 외에도 Combine에는 RxSwift에 없는 try*** 형태의 Operator들이 존재한다. 이는 Result 타입을 사용해서 에러처리 별도로 핸들링 할 수 있게 해준다.

그리고 merge, combineLatest, zip 연산자의 메소드 이름이 묶을 수 있는 Publisher의 갯수에 따라 메소드 이름 뒤에 숫자가 붙어 있다.

Subject

• Rx의 Subject 개념

💡 Combine과 RxSwift에서의 Subject

⭐️ Combine

• PassthroughSubject
• CurrentValueSubject(value에 접근이 가능함. BehaviorSubject+Relay 정도..?)
• ❌
• send(value)

⭐️ RxSwift

• PublishSubject
• BehaviorSubject
• ReplaySubject
• onNext(value)

Cancellable

• Rx의 Disposable 개념

💡 Cancellable vs Disposable

⭐️ Cancellable

• Cancellable
• AnyCancellable
• DisposeBag과 완벽히 매칭되는 개념은 없음

var cancellables = Set<AnyCancellable>()

Just(1)
	.sink { number in 
		print(number)
	}
	.store(in: &cancellables)

• Cancellable을 DisposeBag과 같이 사용할 수 있도록 전수열님이 만든 라이브러리가 있다. → CancelBag

⭐️ Disposable

• Disposable
• DisposeBag

var disposeBag = DisposeBag()

Observable.just(1)
	.subscribe(onNext: { number in 
		print(number)
	})
	.disposeBag(by: disposeBag)