sink는 내부적으로 Subscriber 객체를 만들어 Publisher를 구독하는 메서드에요.

Publisher에서 발행한 값과 이벤트를 처리하기 위한 탈출 클로저를 매개변수로 받아요.

특징

• sink는 Subscriber를 자체 생성해요. 커스텀 Subscriber을 만들때의 번거로움이 없어져요!
• 이 Subscriber의 Demand 값은 기본적으로 무제한(.unlimited)에요. 따라서 Publisher가 발행할 수 있는 모든 값을 받기 전에는 스트림이 종료되지 않아요.
• sink 는 AnyCancellable 타입의 객체를 반환해요. 이 객체는 적절한 변수나 컬렉션에 저장되지 않으면 그 즉시 구독관계가 취소되고 Subscriber는 더 이상 Publisher로부터 어떠한 값이나 이벤트를 받을 수 없어요.

사용

두 가지 형태의 sink 메서드가 있어요.

1. Publisher가 Failure를 가질 수 있는 경우

public func sink(
  receiveCompletion: @escaping ((Subscribers.Completion<Self.Failure>) -> Void),
  receiveValue: @escaping ((Self.Output) -> Void)
) -> AnyCancellable

1. Publisher의 Failure이 Never인 경우