init

杨锴

2024-08-14 909e20941e45f8712c012db602034b47da0bfdb0

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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
//
//  Infallible+Bind.swift
//  RxCocoa
//
//  Created by Shai Mishali on 27/08/2020.
//  Copyright © 2020 Krunoslav Zaher. All rights reserved.
//
 
import RxSwift
 
extension InfallibleType {
    /**
     Creates new subscription and sends elements to observer(s).
     In this form, it's equivalent to the `subscribe` method, but it better conveys intent, and enables
     writing more consistent binding code.
     - parameter observers: Observers to receives events.
     - returns: Disposable object that can be used to unsubscribe the observers.
     */
    public func bind<Observer: ObserverType>(to observers: Observer...) -> Disposable where Observer.Element == Element {
        self.subscribe { infallibleEvent in
            observers.forEach { $0.on(infallibleEvent.event) }
        }
    }
 
    /**
     Creates new subscription and sends elements to observer(s).
     In this form, it's equivalent to the `subscribe` method, but it better conveys intent, and enables
     writing more consistent binding code.
     - parameter observers: Observers to receives events.
     - returns: Disposable object that can be used to unsubscribe the observers.
     */
    public func bind<Observer: ObserverType>(to observers: Observer...) -> Disposable where Observer.Element == Element? {
        self.map { $0 as Element? }
            .subscribe { infallibleEvent in
                observers.forEach { $0.on(infallibleEvent.event) }
            }
    }
 
    /**
    Subscribes to observable sequence using custom binder function.
 
    - parameter binder: Function used to bind elements from `self`.
    - returns: Object representing subscription.
    */
    public func bind<Result>(to binder: (Self) -> Result) -> Result {
        binder(self)
    }
 
    /**
    Subscribes to observable sequence using custom binder function and final parameter passed to binder function
    after `self` is passed.
 
        public func bind<R1, R2>(to binder: Self -> R1 -> R2, curriedArgument: R1) -> R2 {
            return binder(self)(curriedArgument)
        }
 
    - parameter binder: Function used to bind elements from `self`.
    - parameter curriedArgument: Final argument passed to `binder` to finish binding process.
    - returns: Object representing subscription.
    */
    public func bind<R1, R2>(to binder: (Self) -> (R1) -> R2, curriedArgument: R1) -> R2 {
        binder(self)(curriedArgument)
    }
 
    /**
    Subscribes an element handler to an observable sequence.
    In case error occurs in debug mode, `fatalError` will be raised.
    In case error occurs in release mode, `error` will be logged.
 
    - parameter onNext: Action to invoke for each element in the observable sequence.
    - returns: Subscription object used to unsubscribe from the observable sequence.
    */
    public func bind(onNext: @escaping (Element) -> Void) -> Disposable {
        self.subscribe(onNext: onNext)
    }
 
    /**
    Creates new subscription and sends elements to `BehaviorRelay`.
 
    - parameter relays: Target relay for sequence elements.
    - returns: Disposable object that can be used to unsubscribe the observer from the relay.
    */
    public func bind(to relays: BehaviorRelay<Element>...) -> Disposable {
        return self.subscribe(onNext: { e in
            relays.forEach { $0.accept(e) }
        })
    }
 
    /**
     Creates new subscription and sends elements to `BehaviorRelay`.
 
     - parameter relays: Target relay for sequence elements.
     - returns: Disposable object that can be used to unsubscribe the observer from the relay.
     */
    public func bind(to relays: BehaviorRelay<Element?>...) -> Disposable {
        return self.subscribe(onNext: { e in
            relays.forEach { $0.accept(e) }
        })
    }
 
    /**
    Creates new subscription and sends elements to `PublishRelay`.
 
    - parameter relays: Target relay for sequence elements.
    - returns: Disposable object that can be used to unsubscribe the observer from the relay.
    */
    public func bind(to relays: PublishRelay<Element>...) -> Disposable {
        return self.subscribe(onNext: { e in
            relays.forEach { $0.accept(e) }
        })
    }
 
    /**
     Creates new subscription and sends elements to `PublishRelay`.
 
     - parameter relays: Target relay for sequence elements.
     - returns: Disposable object that can be used to unsubscribe the observer from the relay.
     */
    public func bind(to relays: PublishRelay<Element?>...) -> Disposable {
        return self.subscribe(onNext: { e in
            relays.forEach { $0.accept(e) }
        })
    }
 
    /**
    Creates new subscription and sends elements to `ReplayRelay`.
 
    - parameter relays: Target relay for sequence elements.
    - returns: Disposable object that can be used to unsubscribe the observer from the relay.
    */
    public func bind(to relays: ReplayRelay<Element>...) -> Disposable {
        return self.subscribe(onNext: { e in
            relays.forEach { $0.accept(e) }
        })
    }
 
    /**
     Creates new subscription and sends elements to `ReplayRelay`.
 
     - parameter relays: Target relay for sequence elements.
     - returns: Disposable object that can be used to unsubscribe the observer from the relay.
     */
    public func bind(to relays: ReplayRelay<Element?>...) -> Disposable {
        return self.subscribe(onNext: { e in
            relays.forEach { $0.accept(e) }
        })
    }
}