Publisher

Publisher는 시간이 지남에 따라 값의 시퀀스를 전달할 수 있다.

Combine에서 Publisher는 프로토콜로 정의되어 있으며, 다음의 타입이 이 프로토콜을 채택한다.

• Publishers 열거형의 중첩 타입으로 정의된 여러 구조체

• Just, Empty와 같은 Convenience Publisher

• 타입을 지운 Publisher인 AnyPublisher 구조체

• 등등

두 개의 연관 타입이 정의되어 있다.

• 첫 번째 연관 타입은 값의 타입(Output)이다.

• 두 번째 연관 타입은 에러의 타입(Failure)이다.

  • 에러의 타입은 Error 프로토콜을 채택해야 한다.

Publisher 프로토콜의 익스텐션으로 여러 오퍼레이터operator가 정의되어 있으며, 이를 사용해서 이벤트 처리 체인을 구성할 수 있다.

각 오퍼레이터는 Publisher 프로토콜을 구현하는 타입을 반환한다.

기본적으로 Publisher 프로토콜은 오퍼레이터의 이름과 그것이 반환하는 Publisher의 이름을 비슷하게 만들어 두었으나, 이 프로토콜을 채택하는 개별 Publisher는 오퍼레이터가 다른 타입의 Publisher를 반환하게 구현해둘 수 있다.

protocol Publisher { }

extension Publisher {
  func count() -> Publishers.Count<Self>
}

struct Just: Publisher {
  func count() -> Just<Int>
}

Publisher 프로토콜의 익스텐션으로 여러 오퍼레이터가 구현되어 있으나, Just와 같은 개별 Publisher가 오퍼레이터를 오버로딩하여 다른 타입을 반환하도록 구현한 경우를 어렵지 않게 찾아볼 수 있다.

RxSwift

일반적으로 Publisher 프로토콜을 구현하는 타입은 RxSwift의 Observable과 비교 가능하다.

에러 연관 타입이 Never로 에러 값을 전달하지 않는다는 것이 보장되는 것은 RxCocoa의 Driver와 비교 가능하다.

하나의 값을 전달하고 종료하거나, 에러를 내고 종료하는 Single의 동작은 Combine의 Future Publisher를 사용하여 구현할 수 있다.

Completable, Maybe와 같은 RxSwift의 Traits는 Combine에 별도의 타입으로 구현되어 있지 않다.

ReactiveSwift

일반적으로 Publisher 프로토콜을 구현하는 타입은 ReactiveSwift의 SignalProducer와 Signal과 비교 가능하다.

SignalProducer는 'Cold Observable', Signal은 'Hot Observable'을 의미하는데, Combine에서는 이 동작을 별도의 타입으로 구분하지 않는다.

Publisher와 Operator 쌍

Convenience Publishers

Publisher	관련 Operator
Future	-
Just	-
Deferred	-
Empty	-
Fail	-
Record	-

Publisher in Publishers Enum

Convenience Publishers

Publisher	관련 Operator
Sequence	-
Catch	catch

Working with Subscribers

Publisher	관련 Operator
ReceiveOn	receive
SubscribeOn	subscribe

Mapping Elements

Publisher	관련 Operator
TryScan	tryScan
TryMap	tryMap
FlatMap	flatMap
Map	map / replaceNil / combineLatest / zip
MapError	mapError
Scan	scan
SetFailureType	setFailureType

Filtering Elements

Publisher	관련 Operator
CompactMap	compactMap
Filter	filter
RemoveDuplicates	removeDuplicates
ReplaceEmpty	replaceEmpty
ReplaceError	replaceError
TryCompactMap	tryCompactMap
TryFilter	tryFilter
TryRemoveDuplicates	tryRemoveDuplicates

Reducing Elements

Publisher	관련 Operator
Collect	collect
CollectByCount	collect
CollectByTime	collect
IgnoreOutput	ignoreOutput
Reduce	reduce
TryReduce	tryReduce

Applying Mathematical Operations on Elements

Publisher	관련 Operator
Comparison	max / min
TryComparison	tryMax / tryMin
Count	count

Applying Matching Criteria to Elements

Publisher	관련 Operator
TryAllSatisfy	tryAllSatisfy
AllSatisfy	allSatisfy
Contains	contains
ContainsWhere	contains
TryContainsWhere	tryContains

Applying Sequence Operations to Elements

Publisher	관련 Operator
FirstWhere	first
LastWhere	last
DropUntilOutput	drop
DropWhile	drop
TryDropWhile	tryDrop
Concatenate	append / prepend
Drop	dropFirst
PrefixUntilOutput	prefix
PrefixWhile	prefix
First	first
Last	last
TryFirstWhere	tryFirst
TryLastWhere	tryLast
TryPrefixWhile	tryPrefix
Output	output

Combining Elements from Multiple Publishers

Publisher	관련 Operator
CombineLatest	combineLatest
CombineLatest3	combineLatest
CombineLatest4	combineLatest
Merge	merge
Merge3	merge
Merge4	merge
Merge5	merge
Merge6	merge
Merge7	merge
Merge8	merge
MergeMany	merge
Zip	zip
Zip3	zip
Zip4	zip

Handling Errors

Publisher	관련 Operator
AssertNoFailure	assertNoFailure
Catch	catch
TryCatch	tryCatch
Retry	retry

Adapting Publisher Types

Publisher	관련 Operator
SwitchToLatest	switchToLatest

Controlling Timing

Publisher	관련 Operator
Debounce	debounce
Delay	delay
MeasureInterval	measureInterval
Throttle	throttle
Timeout	timeout

Creating Reference-type Publishers

Publisher	관련 Operator
Share	share

Encoding and Decoding

Publisher	관련 Operator
Encode	encode
Decode	decode

Identifying Properties with Key Paths

Publisher	관련 Operator
MapKeyPath	map
MapKeyPath2	map
MapKeyPath3	map

Using Explicit Publisher Connections

Publisher	관련 Operator
Autoconnect	autoconnect

Working with Multiple Subscribers

Publisher	관련 Operator
Multicast	multicast

Buffering Elements

Publisher	관련 Operator
Buffer	buffer

Adding Explicit Connectability

Publisher	관련 Operator
MakeConnectable	makeConnectable

Debugging

Publisher	관련 Operator
Breakpoint	breakpoint / breakpointOnError
HandleEvents	handleEvents
Print	print

Misc.

Publisher	관련 Operator
AnyPublisher	eraseToAnyPublisher
NotificationCenter.Publisher	-
Optional.Publisher	-
Result.Publisher	-
URLSession.DataTaskPublisher	-
Timer.TimerPublisher	-