Subject.swift

import ReactiveSwift
import enum Result.NoError

public final class Subject<Value, Error: Swift.Error>: SignalProtocol, ObserverProtocol {
  private let (_signal, observer) = Signal<Value, Error>.pipe()

  public var signal: Signal<Value, Error> {
    return _signal
  }

  public func observe(_ observer: Observer<Value, Error>) -> Disposable? {
    return _signal.observe(observer)
  }

  public func send(value: Value) {
    observer.send(value: value)
  }

  public func send(error: Error) {
    observer.send(error: error)
  }

  public func sendCompleted() {
    observer.sendCompleted()
  }

  public func sendInterrupted() {
    observer.sendInterrupted()
  }
}