1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
// RUN: %target-swift-frontend -emit-ir %s
// https://github.com/apple/swift/issues/46601
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)
}
}
|
