File tree 1 file changed +4
-3
lines changed
Sources/GraphQL/Subscription 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 3
3
import RxSwift
4
4
5
5
/// Abstract event stream class - Should be overridden for actual implementations
6
- public class EventStream < Element> {
6
+ open class EventStream < Element> {
7
+ public init ( ) { }
7
8
/// Template method for mapping an event stream to a new generic type - MUST be overridden by implementing types.
8
- func map< To> ( _ closure: @escaping ( Element ) throws -> To ) -> EventStream < To > {
9
+ open func map< To> ( _ closure: @escaping ( Element ) throws -> To ) -> EventStream < To > {
9
10
fatalError ( " This function should be overridden by implementing classes " )
10
11
}
11
12
}
@@ -19,7 +20,7 @@ public class ObservableEventStream<Element> : EventStream<Element> {
19
20
init ( _ observable: Observable < Element > ) {
20
21
self . observable = observable
21
22
}
22
- override func map< To> ( _ closure: @escaping ( Element ) throws -> To ) -> EventStream < To > {
23
+ override open func map< To> ( _ closure: @escaping ( Element ) throws -> To ) -> EventStream < To > {
23
24
return ObservableEventStream < To > ( observable. map ( closure) )
24
25
}
25
26
}
You can’t perform that action at this time.
0 commit comments