<div id="readability-page-1" class="page"><div><h2 id="custom-publisher">Custom Publisher</h2>
<ul>
<li><code>Publisher</code> 프로토콜을 직접 구현하는 대신 Combine 프레임워크가 제공하는 타입들을 이용하면 간편하게 Custom Publisher를 구현할 수 있다.</li>
</ul>
<h2 id="1-subject">1. Subject</h2>
<p>Subject 는 값을 외부에서 publish할 수 있는 메서드를 제공하는 Publisher protocol이다. </p>
<p>값을 주입할 때에는 <code>send(_:)</code> 메서드를 이용한다.</p>
<p><strong>PassthroughSubject</strong>(final class)</p>
<ul>
<li>conforms to <em>Publisher</em> and <em>Subject</em></li>
<li>downstream subscriber들에게 값을 전달한다.</li>
<li>Subject protocol의 구현체이다.</li>
<li>초기값이나 버퍼를 가지고 있지 않기 때문에 해당 publisher를 구독하고 있는 subscriber가 없거나, 있더라도 demand가 0이라면 그냥 값을 없애버린다.<br>
<img src="https://velog.velcdn.com/images/jujube0/post/71fae07f-b331-4c71-a212-814c924443ae/image.png"></li>
</ul>
<p><strong>CurrentValueSubject</strong>(final class)</p>
<ul>
<li>conforms to <em>Publisher</em> and <em>Subject</em></li>
<li>초기값과 함께 초기화된다.</li>
<li><code>value</code> 프로퍼티를 가지고 있으면서 <code>send(_:)</code> 메서드가 호출될 때마다 <code>value</code> 를 해당 값으로 갱신한다. → <code>value</code> 를 통해 가장 최근에 pubilsh된 값에 접근할 수 있다.</li>
<li>subscribe 되면 가지고 있는 최신값, <code>value</code> 를 보내준다.</li>
</ul>
<p><img src="https://velog.velcdn.com/images/jujube0/post/bf63212e-58a5-4aaf-a97c-062f7d3cd891/image.png"></p>
<p><img src="https://velog.velcdn.com/images/jujube0/post/52d67720-b7ff-4f93-af56-8ca8ebe0c4f5/image.png"></p>
<h2 id="2--published">2.  Published</h2>
<p>타입 프로퍼티에 <code>@Published</code> 를 추가하여 해당 프로퍼티의 값이 변경될 때마다 값을 보내주는 publisher를 생성할 수 있다. <code>$</code> 를 프로퍼티 이름 앞에 추가하여 publisher에 접근한다.<br>
<img src="https://velog.velcdn.com/images/jujube0/post/a3bb2733-77ed-4b3c-b1dc-b2e0c64c187f/image.png"></p>
<ul>
<li><code>willSet</code> 블록에서 publishing이 일어난다. 즉, 실제 값이 프로퍼티에 적용되기 전에 subscriber는 값을 받게 된다.</li>
<li>class 내 프로퍼티에만 적용 가능하다.</li>
</ul>
<h2 id="anypublisher">AnyPublisher</h2>
<p><img src="https://velog.velcdn.com/images/jujube0/post/44d43312-cef1-4b66-aa58-27b2fc5488f3/image.png"></p>
<p>고유한 프로퍼티를 가지지 않는, publisher의 구현체이다. upstream publisher로부터 받은 값들과 completion(성공/실패 여부)들을 전달해주는 역할은 유지하고 있으므로 타입 특이적인 정보를 지우는 데(type erasure) 이용된다. </p>
<ul>
<li>모듈간 publisher를 전달할 때</li>
<li>값을 직접 주입(by <code>send(_:)</code>) 가능한 Subject 등에서 타입에 의존되는 메서드나 프로퍼티를 감추고 싶을 때</li>
</ul>
<p>이용하면 좋다. </p>
<ul>
<li>publisher의 타입을 노출하지 않으므로, 내부에서 Output, Failure 타입을 변경하지 않는 한에서 publisher 타입이나 내부 구현을 수정해도 이를 이용하는 클라이언트들에게 영향을 끼치지 않는다는 장점이 있다.</li>
<li><code>eraseToAnyPublisher()</code> operator를 통해 publisher를 AnyPublisher로 간단하게 wrap할 수 있다.</li>
</ul>
<h2 id="custom-subscriber">Custom Subscriber</h2>
<h2 id="cancellable">Cancellable</h2>
<p><strong>A protocol indicating that an activity or action supports cancellation.</strong></p>
<ul>
<li><code>cancel()</code> 을 호출하여 할당된 리소스들을 제거하고 subscription을 중단한다.</li>
<li><strong>AnyCancellable</strong>: AnyPublisher처럼 type을 지운 (type-erasing) cancellable object.<ul>
<li>deinit될 때 자동으로 <code>cancel()</code> 을 호출한다. AnyCancellable로 subscription을 property에 저장해두면 해당 인스턴스가 메모리에서 제거될 때 subscription과 할당된 메모리를 자동으로 해제한다.</li>
<li><code>store(in:)</code> 을 통해 collection이나 set에 cancellable instance를 저장할 수도 있다.</li>
</ul></li>
<li>Subscriber comforms to Cancellable</li>
</ul>
<h2 id="custom-subscriber-1">Custom Subscriber</h2>
<p><strong>Publisher로부터 Subscriber가 값을 받기 위해서는 1. Subscription이 필요하고, 2. Demand(값을 요청하는 것)가 필요하다.</strong></p>
<p><strong>Demand</strong></p>
<ul>
<li>값을 요청하기 위해서는 <a href="https://developer.apple.com/documentation/combine/subscribers/demand">Subscribers.Demand</a> 타입을 이용한다.</li>
<li>publisher로부터 요청한 만큼의 값만 받기 때문에, 처리 속도에 맞게 조절이 가능하다.</li>
<li>값을 요청하는 방법으로는 두 가지가 있다.<ol>
<li>publisher는 subscriber가 처음 구독(subscribe)할 때 Subscription 인스턴스를 제공한다. 해당 인스턴스에 <code>request(_:)</code> 메서드를 호출하여 값을 요청한다.</li>
<li>publisher는 subscriber에게 값을 전달 할 때 subscriber의 <code>receive(_:)</code> 메서드를 호출한다. 메서드의 리턴 값으로 Demand를 리턴한다.</li>
</ol></li>
<li>추가로 Demand는 항상 증가하기만 한다. 새로운 Demand는 이전의 요청과 합산되고, Demand로 음수를 보낼 수도 없다.</li>
</ul>
<p><strong>high or unlimited demand</strong></p>
<ul>
<li><code>sink(receiveValue:)</code> , <code>assign(to:on:)</code> 을 통해 생성되는 편의 Subscriber는 처음 publisher와 연결되자마자 <code>unlimited</code> Demand를 보낸다.</li>
<li>이런식으로 unlimited 또는 높은 수의 demand를 보내면, subscriber가 요청하는 것보다 빠른 속도로 값이 생성되어 메모리에 부하가 쌓이거나 값이 유실될 수 있다. 그렇기에 주의가 필요하다.</li>
<li>대부분의 UI 관련 publisher들은 그렇게 빠른 속도로 값을 생성하지 않거나 하나의 값만 보내고 종료하기 때문에 sink / assign subscriber를 써도 괜찮다.</li>
<li>직접 demand를 제어하기 위해서는 custom subscriber를 이용하거나, Back-Pressure Operators를 이용해야한다.</li>
</ul>
<p><strong>custom subscriber</strong></p>
<p><img src="https://velog.velcdn.com/images/jujube0/post/56e220a1-e5c7-49d8-a7c8-e21590223074/image.png"></p>
<ul>
<li>subscription을 통해 1개의 값만 요청하고 있으므로 처음 생성된 “Hello” 만 출력됐다.</li>
<li>publisher가 completion을 호출하고 있지 않으므로 <code>"--done--"</code> 도 아직 출력되지 않았다.</li>
<li><code>publisher.send(completion: .finished)</code> 를 호출하여 완료하거나, 그 전에 subscription 객체를 이용해서 새로운 demand를 보낼 수도 있다.</li>
</ul>
<h2 id="reference">Reference</h2>
<ul>
<li>Documentation / Combine / Publisher <a href="https://developer.apple.com/documentation/combine/publisher">https://developer.apple.com/documentation/combine/publisher</a></li>
<li>Documentation / Combine / Published <a href="https://developer.apple.com/documentation/combine/published">https://developer.apple.com/documentation/combine/published</a></li>
<li>Documentation / Combine / AnyPublisher <a href="https://developer.apple.com/documentation/combine/anypublisher">https://developer.apple.com/documentation/combine/anypublisher</a></li>
<li>Documentation / Combine / Cancellable <a href="https://developer.apple.com/documentation/combine/cancellable">https://developer.apple.com/documentation/combine/cancellable</a></li>
<li>Documentation / Combine / Processing Published Elements with Subscribers <a href="https://developer.apple.com/documentation/combine/processing-published-elements-with-subscribers">https://developer.apple.com/documentation/combine/processing-published-elements-with-subscribers</a></li>
</ul></div></div>

jujube0

Custom Publisher
Publisher 프로토콜을 직접 구현하는 대신 Combine 프레임워크가 제공하는 타입들을 이용하면 간편하게 Custom Publisher를 구현할 수 있다.
1. Subject
Subject 는 값을 외부에서 publish할 수 있는 메서드를 제공하는 Publisher protocol이다. 
값을 주입할 때에는 send(_:) 메서드를 이용한다.
PassthroughSubject(final class)
conforms to Publisher and Subject
downstream subscriber들에게 값을 전달한다.
Subject protocol의 구현체이다.
초기값이나 버퍼를 가지고 있지 않기 때문에 해당 publisher를 구독하고 있는 subscriber가 없거나, 있더라도 demand가 0이라면 그냥 값을 없애버린다.
CurrentValueSubject(final class)
conforms to Publisher and Subject
초기값과 함께 초기화된다.
value 프로퍼티를 가지고 있으면서 send(_:) 메서드가 호출될 때마다 value 를 해당 값으로 갱신한다. → value 를 통해 가장 최근에 pubilsh된 값에 접근할 수 있다.
subscribe 되면 가지고 있는 최신값, value 를 보내준다.
2.  Published
타입 프로퍼티에 @Published 를 추가하여 해당 프로퍼티의 값이 변경될 때마다 값을 보내주는 publisher를 생성할 수 있다. $ 를 프로퍼티 이름 앞에 추가하여 publisher에 접근한다.
willSet 블록에서 publishing이 일어난다. 즉, 실제 값이 프로퍼티에 적용되기 전에 subscriber는 값을 받게 된다.
class 내 프로퍼티에만 적용 가능하다.
AnyPublisher
고유한 프로퍼티를 가지지 않는, publisher의 구현체이다. upstream publisher로부터 받은 값들과 completion(성공/실패 여부)들을 전달해주는 역할은 유지하고 있으므로 타입 특이적인 정보를 지우는 데(type erasure) 이용된다. 
모듈간 publisher를 전달할 때
값을 직접 주입(by send(_:)) 가능한 Subject 등에서 타입에 의존되는 메서드나 프로퍼티를 감추고 싶을 때
이용하면 좋다. 
publisher의 타입을 노출하지 않으므로, 내부에서 Output, Failure 타입을 변경하지 않는 한에서 publisher 타입이나 내부 구현을 수정해도 이를 이용하는 클라이언트들에게 영향을 끼치지 않는다는 장점이 있다.
eraseToAnyPublisher() operator를 통해 publisher를 AnyPublisher로 간단하게 wrap할 수 있다.
Custom Subscriber
Cancellable
A protocol indicating that an activity or action supports cancellation.
cancel() 을 호출하여 할당된 리소스들을 제거하고 subscription을 중단한다.
AnyCancellable: AnyPublisher처럼 type을 지운 (type-erasing) cancellable object.
deinit될 때 자동으로 cancel() 을 호출한다. AnyCancellable로 subscription을 property에 저장해두면 해당 인스턴스가 메모리에서 제거될 때 subscription과 할당된 메모리를 자동으로 해제한다.
store(in:) 을 통해 collection이나 set에 cancellable instance를 저장할 수도 있다.
Subscriber comforms to Cancellable
Custom Subscriber
Publisher로부터 Subscriber가 값을 받기 위해서는 1. Subscription이 필요하고, 2. Demand(값을 요청하는 것)가 필요하다.
Demand
값을 요청하기 위해서는 Subscribers.Demand 타입을 이용한다.
publisher로부터 요청한 만큼의 값만 받기 때문에, 처리 속도에 맞게 조절이 가능하다.
값을 요청하는 방법으로는 두 가지가 있다.
publisher는 subscriber가 처음 구독(subscribe)할 때 Subscription 인스턴스를 제공한다. 해당 인스턴스에 request(_:) 메서드를 호출하여 값을 요청한다.
publisher는 subscriber에게 값을 전달 할 때 subscriber의 receive(_:) 메서드를 호출한다. 메서드의 리턴 값으로 Demand를 리턴한다.
추가로 Demand는 항상 증가하기만 한다. 새로운 Demand는 이전의 요청과 합산되고, Demand로 음수를 보낼 수도 없다.
high or unlimited demand
sink(receiveValue:) , assign(to:on:) 을 통해 생성되는 편의 Subscriber는 처음 publisher와 연결되자마자 unlimited Demand를 보낸다.
이런식으로 unlimited 또는 높은 수의 demand를 보내면, subscriber가 요청하는 것보다 빠른 속도로 값이 생성되어 메모리에 부하가 쌓이거나 값이 유실될 수 있다. 그렇기에 주의가 필요하다.
대부분의 UI 관련 publisher들은 그렇게 빠른 속도로 값을 생성하지 않거나 하나의 값만 보내고 종료하기 때문에 sink / assign subscriber를 써도 괜찮다.
직접 demand를 제어하기 위해서는 custom subscriber를 이용하거나, Back-Pressure Operators를 이용해야한다.
custom subscriber
subscription을 통해 1개의 값만 요청하고 있으므로 처음 생성된 “Hello” 만 출력됐다.
publisher가 completion을 호출하고 있지 않으므로 "--done--" 도 아직 출력되지 않았다.
publisher.send(completion: .finished) 를 호출하여 완료하거나, 그 전에 subscription 객체를 이용해서 새로운 demand를 보낼 수도 있다.
Reference
Documentation / Combine / Publisher https://developer.apple.com/documentation/combine/publisher
Documentation / Combine / Published https://developer.apple.com/documentation/combine/published
Documentation / Combine / AnyPublisher https://developer.apple.com/documentation/combine/anypublisher
Documentation / Combine / Cancellable https://developer.apple.com/documentation/combine/cancellable
Documentation / Combine / Processing Published Elements with Subscribers https://developer.apple.com/documentation/combine/processing-published-elements-with-subscribers

4. Combine: Publisher와 Subscriber (2)

댓글