<div id="readability-page-1" class="page"><div><h2 id="publisher와-subscriber">Publisher와 Subscriber</h2>
<ul>
<li>Publisher는 시간에 따라 변화하는 값들을 전송해주는 프로토콜이다. 값을 하나만 전달해줄 수도 있고, 여러개 전달해줄 수도 있다. 하나도 전달하지 않을 수도 있다.</li>
<li>Publisher는 <strong>Output</strong>과 <strong>Failure</strong>, 두 개의 associated type을 갖는다.<ul>
<li><strong>Output</strong> : publisher가 전송할 값의 Type</li>
<li><strong>Failure</strong> : publisher가 전송할 수 있는 error의 Type</li>
</ul></li>
<li>Subscriber는 publisher로부터 값을 전달받는 프로토콜이다. 역시 두 개의 associated type을 가진다.<ul>
<li><strong>Input</strong> : subscriber가 전달받을 Type. 값을 전달받을 Publisher.Output의 타입과 동일해야한다.</li>
<li><strong>Failure</strong> : subscriber가 전달받을 수 있는 에러의 타입. 역시 Publisher.Failure와 동일해야한다.</li>
</ul></li>
<li>Apple이 제공하는 built-in subscriber인 <code>sink(..)</code> 와 <code>assign(..)</code> 은 자동으로 Input과 Failure를 연결된 publisher와 동일하게 맞춰준다.</li>
</ul>
<h2 id="연결하기">연결하기</h2>
<p><strong>publisher는 subscriber가 1. 연결되고 2. 값을 요청했을 때에만 값을 전달할 수 있다.</strong></p>
<p>이를 위해 publisher와 subscriber는 각각 하나, 세 개의 required method를 가진다.</p>
<ul>
<li>publisher<ul>
<li><code>receive&lt;S&gt;(subscriber: S)</code> : subscriber를 publisher에 연결해준다.</li>
</ul></li>
<li>subscriber<ul>
<li><code>receive(Self.Input) -&gt; Subscribers.Demand</code> : subscriber에게 publisher가 element(값)를 생성했음을 알려준다.</li>
<li><code>receive(subscription: Subscription)</code> : subscriber에게 publisher와의 연결이 성공했고, 값을 요청가능함을 알려준다.</li>
<li><code>receive(completion: Subscribers.Completion&lt;Self.Failure&gt;</code> : subscriber에게 publisher가 값 전달을 완료했음을 알려준다(성공/실패의 여부와 함께)</li>
</ul></li>
</ul>
<p><strong>그럼 해당 메서드를 이용해서 publisher와 subscriber가 연결되는 과정에 대해 알아보자</strong></p>
<p><strong>1. 연결(subscribe)</strong></p>
<ul>
<li><code>publisher.subscribe(subscriber)</code>  publisher가 subscriber에게 값을 전달해주기 위해서는 일단 subscriber가 publisher를 구독(subscribe)하여 연결되어야 한다.  이는 publisher의 <code>subscribe(_:)</code> 메서드를 통해 이루어진다. 해당 메서드는 publisher의 required method인 <code>receive(subscriber: S)</code> 를 호출한다.<br>
</li>
<li>publisher의 subscribe(:) 가 호출되면, publisher는 subscriber의 <code>receive(subscription: Subscription)</code> 을 호출한다. subscription을 이용하여 subscriber는<ul>
<li>값을 달라고 요청하거나</li>
<li>subscription을 취소해서 값을 전달받는 것을 중단한다.</li>
</ul></li>
<li>연결(또는 구독)을 마친 후여도 subscriber가 값을 달라고 요청하지 않으면 publisher는 값을 주지 않는다.</li>
</ul>
<p><strong>2. 값을 요청하기</strong></p>
<ul>
<li><code>Subscriber.request(Subscribers.Demand)</code>  를 이용해서 요청할 수 있다. <code>.unlimited</code> , <code>.max(Int)</code>, <code>.none</code> 등이 있다.<br>
</li>
<li><code>sink(receiveValue:)</code> 의 경우 연결된 후 즉시 unlimited 를 요청한다.</li>
</ul>
<p><strong>3.값을 전달하기</strong></p>
<ul>
<li><code>subscriber.receive(_)</code>  publisher는 값을 요청받은 후 위 메서드를 호출하여 값을 전달해준다.<br>
</li>
<li><code>subscriber.receive(completion:)</code>  값을 모두 전달한 후에는 위 메서드를 통해 정상적으로 요청을 마쳤는지, 실패했는지를 알려준다. completion을 전달한 후에는 값을 다시 생성할 수 없다.<br>
</li>
</ul>
<p><strong>Cancellables</strong></p>
<ul>
<li>앞에서 언급한 두 개의 built-in subscriber는 cancellable을 리턴한다. 그 외의 subscriber에서는 publisher가 subscriber의 <code>receive(subscription:)</code> 을 호출함으로써 Cancellable을 상속하는 Subscription을 전달해준다.</li>
<li>Cancellable의 <code>cancel()</code> 메서드를 호출하면 subscription이 중단되고, publisher는 값을 더이상 생성하지 않게 된다.</li>
<li>type-erasing cancellable object인 <code>AnyCancellable</code> 을 이용하면 subscription의 수명을 손쉽게 제어할 수 있다. AnyCancellable은 deinit 될 때 자동으로 cancel()을 호출하기 때문. AnyCancellable로 모든 subscription을 property로 저장해두면 해당 인스턴스가 메모리에서 제거될 때 subscription도 자동으로 제거된다.</li>
</ul>
<h2 id="convenience-publisher">Convenience Publisher</h2>
<p>Combine이 이미 제공하는 Publisher 클래스를 이용할 수 있다.</p>
<h2 id="1-future">1. Future</h2>
<ul>
<li>하나의 값을 전달하고 종료하는 Publisher이다.</li>
<li>Future은 promise 클로져를 통해 초기화된다. 값을 생성하기 위해 해당 클로져를 실행하므로, 비동기적으로 값을 생성하고 싶을 때 이용한다.</li>
</ul>
<p><img src="https://velog.velcdn.com/images/jujube0/post/06ea38fa-c175-4a0c-b73f-bb9a754bfa5b/image.png"></p>
<ul>
<li>예시는 하나의 랜덤한 Int 값을 전달해주는 publisher이다. 값이 생성될 때까지 시간이 소요되므로(asyncAfter) promise closure를 이용했다. 항상 성공적으로 Int 값을 전달해주므로 Failure Type은 Never이다. 아래처럼 이용 가능하다.</li>
</ul>
<p><img src="https://velog.velcdn.com/images/jujube0/post/bcf289f5-9f8c-4e44-a075-c637659edb64/image.png"></p>
<h2 id="2-just">2. Just</h2>
<ul>
<li>Output 타입의 값으로 초기화되는 Publisher이다. output을 그대로 전달해준다.<br>
값을 그대로 전달하는 역할을 하기 때문에 실패할 수 없다.</li>
<li>이벤트 없이 publisher chain을 시작하고 싶을 때, 또는 다른 publisher와 어떤 값을 연결해주고 싶을 때 그 Just(<code>어떤 값</code>) 을 통해 Publisher를 만들어서 operator로 연결해줄 수 있다.</li>
</ul>
<p><img src="https://velog.velcdn.com/images/jujube0/post/0b7a06e2-b349-45ee-bf76-45e71f724a40/image.png"></p>
<h2 id="3-deferred">3. Deferred</h2>
<ul>
<li>Publisher를 리턴하는 클로져로 초기화된다. subscribe(_:)가 호출되면 해당 클로져가 실행된다. (Future의 경우 <code>.request(Subscribers.Demand)</code> 를 통해 값을 요청받은 후 promise 클로져를 실행한다)  클로져가 모두 실행된 후에야 subscription이 완료된다.<br>
</li>
</ul>
<h2 id="4-empty">4. Empty</h2>
<ul>
<li>값을 절대 전달하지 않는 publisher이다.</li>
<li><code>completeImmediately:Bool</code> 을 초기화할 때 받는다. completion을 즉시 전달할 지 여부이다.</li>
</ul>
<h2 id="5-fail">5. Fail</h2>
<ul>
<li>init(error: Failure) 를 통해 초기화되어 error를 바로 전달하면서 종료된다.</li>
</ul>
<h2 id="6-record">6. Record</h2>
<ul>
<li>원래 subscriber는 publisher와 연결된 이후(<code>subscribe(_:)</code>를 호출한 후)에 전달된 값과 completion만 받을 수 있다. Record는 input과 completion을 저장해놨다가 subscriber가 연결되면 연결 전의 input과 completion을 그대로 전달(playback)해준다.</li>
</ul>
<h2 id="reference">Reference</h2>
<ul>
<li><a href="https://developer.apple.com/documentation/combine/publisher">https://developer.apple.com/documentation/combine/publisher</a></li>
</ul></div></div>

jujube0

Publisher와 Subscriber
Publisher는 시간에 따라 변화하는 값들을 전송해주는 프로토콜이다. 값을 하나만 전달해줄 수도 있고, 여러개 전달해줄 수도 있다. 하나도 전달하지 않을 수도 있다.
Publisher는 Output과 Failure, 두 개의 associated type을 갖는다.
Output : publisher가 전송할 값의 Type
Failure : publisher가 전송할 수 있는 error의 Type
Subscriber는 publisher로부터 값을 전달받는 프로토콜이다. 역시 두 개의 associated type을 가진다.
Input : subscriber가 전달받을 Type. 값을 전달받을 Publisher.Output의 타입과 동일해야한다.
Failure : subscriber가 전달받을 수 있는 에러의 타입. 역시 Publisher.Failure와 동일해야한다.
Apple이 제공하는 built-in subscriber인 sink(..) 와 assign(..) 은 자동으로 Input과 Failure를 연결된 publisher와 동일하게 맞춰준다.
연결하기
publisher는 subscriber가 1. 연결되고 2. 값을 요청했을 때에만 값을 전달할 수 있다.
이를 위해 publisher와 subscriber는 각각 하나, 세 개의 required method를 가진다.
publisher
receive<S>(subscriber: S) : subscriber를 publisher에 연결해준다.
subscriber
receive(Self.Input) -> Subscribers.Demand : subscriber에게 publisher가 element(값)를 생성했음을 알려준다.
receive(subscription: Subscription) : subscriber에게 publisher와의 연결이 성공했고, 값을 요청가능함을 알려준다.
receive(completion: Subscribers.Completion<Self.Failure> : subscriber에게 publisher가 값 전달을 완료했음을 알려준다(성공/실패의 여부와 함께)
그럼 해당 메서드를 이용해서 publisher와 subscriber가 연결되는 과정에 대해 알아보자
1. 연결(subscribe)
publisher.subscribe(subscriber)
  publisher가 subscriber에게 값을 전달해주기 위해서는 일단 subscriber가 publisher를 구독(subscribe)하여 연결되어야 한다.
  이는 publisher의 subscribe(_:) 메서드를 통해 이루어진다. 해당 메서드는 publisher의 required method인 receive(subscriber: S) 를 호출한다.
publisher의 subscribe(:) 가 호출되면, publisher는 subscriber의 receive(subscription: Subscription) 을 호출한다. subscription을 이용하여 subscriber는
값을 달라고 요청하거나
subscription을 취소해서 값을 전달받는 것을 중단한다.
연결(또는 구독)을 마친 후여도 subscriber가 값을 달라고 요청하지 않으면 publisher는 값을 주지 않는다.
2. 값을 요청하기
Subscriber.request(Subscribers.Demand)
  를 이용해서 요청할 수 있다. .unlimited , .max(Int), .none 등이 있다.
sink(receiveValue:) 의 경우 연결된 후 즉시 unlimited 를 요청한다.
3.값을 전달하기
subscriber.receive(_)
  publisher는 값을 요청받은 후 위 메서드를 호출하여 값을 전달해준다.
subscriber.receive(completion:)
  값을 모두 전달한 후에는 위 메서드를 통해 정상적으로 요청을 마쳤는지, 실패했는지를 알려준다. completion을 전달한 후에는 값을 다시 생성할 수 없다.
Cancellables
앞에서 언급한 두 개의 built-in subscriber는 cancellable을 리턴한다. 그 외의 subscriber에서는 publisher가 subscriber의 receive(subscription:) 을 호출함으로써 Cancellable을 상속하는 Subscription을 전달해준다.
Cancellable의 cancel() 메서드를 호출하면 subscription이 중단되고, publisher는 값을 더이상 생성하지 않게 된다.
type-erasing cancellable object인 AnyCancellable 을 이용하면 subscription의 수명을 손쉽게 제어할 수 있다. AnyCancellable은 deinit 될 때 자동으로 cancel()을 호출하기 때문. AnyCancellable로 모든 subscription을 property로 저장해두면 해당 인스턴스가 메모리에서 제거될 때 subscription도 자동으로 제거된다.
Convenience Publisher
Combine이 이미 제공하는 Publisher 클래스를 이용할 수 있다.
1. Future
하나의 값을 전달하고 종료하는 Publisher이다.
Future은 promise 클로져를 통해 초기화된다. 값을 생성하기 위해 해당 클로져를 실행하므로, 비동기적으로 값을 생성하고 싶을 때 이용한다.
예시는 하나의 랜덤한 Int 값을 전달해주는 publisher이다. 값이 생성될 때까지 시간이 소요되므로(asyncAfter) promise closure를 이용했다. 항상 성공적으로 Int 값을 전달해주므로 Failure Type은 Never이다. 아래처럼 이용 가능하다.
2. Just
Output 타입의 값으로 초기화되는 Publisher이다. output을 그대로 전달해준다. 
값을 그대로 전달하는 역할을 하기 때문에 실패할 수 없다.
이벤트 없이 publisher chain을 시작하고 싶을 때, 또는 다른 publisher와 어떤 값을 연결해주고 싶을 때 그 Just(어떤 값) 을 통해 Publisher를 만들어서 operator로 연결해줄 수 있다.
3. Deferred
Publisher를 리턴하는 클로져로 초기화된다. subscribe(_:)가 호출되면 해당 클로져가 실행된다. (Future의 경우 .request(Subscribers.Demand) 를 통해 값을 요청받은 후 promise 클로져를 실행한다)
  클로져가 모두 실행된 후에야 subscription이 완료된다.
4. Empty
값을 절대 전달하지 않는 publisher이다.
completeImmediately:Bool 을 초기화할 때 받는다. completion을 즉시 전달할 지 여부이다.
5. Fail
init(error: Failure) 를 통해 초기화되어 error를 바로 전달하면서 종료된다.
6. Record
원래 subscriber는 publisher와 연결된 이후(subscribe(_:)를 호출한 후)에 전달된 값과 completion만 받을 수 있다. Record는 input과 completion을 저장해놨다가 subscriber가 연결되면 연결 전의 input과 completion을 그대로 전달(playback)해준다.
Reference
https://developer.apple.com/documentation/combine/publisher

3. Combine: Publisher와 Subscriber

댓글