blob: e76c28788429ab1bca8119a4508dfc0152102b95 [file] [log] [blame]
// RUN: %target-swift-frontend -emit-ir %s
public enum Event<Element, Error: Swift.Error> {
case next(Element)
case failed(Error)
case completed
}
public typealias Observer<Element, Error: Swift.Error> = (Event<Element, Error>) -> Void
public protocol Disposable {
func dispose()
var isDisposed: Bool { get }
}
public protocol SignalProtocol {
/// The type of elements generated by the signal.
associatedtype Element
/// The type of error that can terminate the signal.
associatedtype Error: Swift.Error
/// Register an observer that will receive events from a signal.
/// This actually triggers event production. Use the returned disposable
/// to unsubscribe and cancel event production.
func observe(with observer: @escaping Observer<Element, Error>) -> Disposable
}
public protocol ObserverProtocol {
/// Type of elements being received.
associatedtype Element
/// Type of error that can be received.
associatedtype Error: Swift.Error
/// Send the event to the observer.
func on(_ event: Event<Element, Error>)
}
/// A type that is both a signal and an observer.
public protocol SubjectProtocol: SignalProtocol, ObserverProtocol {
}
public final class AnySubject<Element, Error: Swift.Error>: SubjectProtocol {
private let baseObserve: (@escaping Observer<Element, Error>) -> Disposable
private let baseOn: Observer<Element, Error>
public init<S: SubjectProtocol>(base: S) where S.Element == Element, S.Error == Error {
baseObserve = base.observe
baseOn = base.on
}
public func on(_ event: Event<Element, Error>) {
return baseOn(event)
}
public func observe(with observer: @escaping Observer<Element, Error>) -> Disposable {
return baseObserve(observer)
}
}