Subject

<aside> 👉 stream에 send(_:)를 호출해 값을 주입할 수 있는 Publisher

</aside>

• 다음과 같이 구현되어 있습니다.

  @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
  public protocol Subject : AnyObject, Publisher {
      func send(_ value: Self.Output)
      func send(completion: Subscribers.Completion<Self.Failure>)
      func send(subscription: Subscription)
  }
  
  extension Subject Where Self.Output == Void {
      public func send()
  }
  

CurrentValueSubject

<aside> 👉 가장 최근에 Published된 값의 버퍼를 유지하는 Publisher

</aside>

• 다음과 같이 구현되어 있습니다.

  @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
  final public class CurrentValueSubject<Output, Failure> : Subject where Failure : Error {
      final public var value: Output
      
      public init(_ value: Output)
  
      final public func receive<S>(subscriber: S) where Output == S.Input, Failure == S.Failure, S : Subscriber
      
      final public func send(subscription: Subscription)
      final public func send(_ input: Output)
      final public func send(completion: Subscribers.Completion<Failure>)
  }
  

PassthroughSubject

<aside> 👉 downstream의 subscriber들에게 값을 전하는 Publisher

</aside>

• 다음과 같이 구현되어 있습니다.

  @available(macOS 10.15, iOS 13.0, tvOS 13.0, watchOS 6.0, *)
  final public class PassthroughSubject<Output, Failure> : Subject where Failure : Error {
  
      public init()
      
      final public func receive<S>(subscriber: S) where Output == S.Input, Failure == S.Failure, S : Subscriber
      
      final public func send(subscription: Subscription)
      final public func send(_ input: Output)
      final public func send(completion: Subscribers.Completion<Failure>)
  }