@@ -28,7 +28,7 @@ public extension Publisher {
28
28
29
29
@available ( OSX 10 . 15 , iOS 13 . 0 , tvOS 13 . 0 , watchOS 6 . 0 , * )
30
30
public extension Publishers {
31
- final class ConcatMap < NewPublisher, Upstream> : Publisher where NewPublisher: Publisher , Upstream: Publisher , NewPublisher. Failure == Upstream . Failure {
31
+ struct ConcatMap < NewPublisher, Upstream> : Publisher where NewPublisher: Publisher , Upstream: Publisher , NewPublisher. Failure == Upstream . Failure {
32
32
public typealias Transform = ( Upstream . Output ) -> NewPublisher
33
33
public typealias Output = NewPublisher . Output
34
34
public typealias Failure = Upstream . Failure
@@ -88,8 +88,7 @@ private extension Publishers.ConcatMap {
88
88
// MARK: - Sink
89
89
@available ( OSX 10 . 15 , iOS 13 . 0 , tvOS 13 . 0 , watchOS 6 . 0 , * )
90
90
private extension Publishers . ConcatMap {
91
- final class Sink < Downstream: Subscriber > : CombineExt . Sink < Upstream , Downstream >
92
- where Downstream. Input == Output , Downstream. Failure == Failure {
91
+ final class Sink < Downstream: Subscriber > : CombineExt . Sink < Upstream , Downstream > where Downstream. Input == Output , Downstream. Failure == Failure {
93
92
private let lock = NSRecursiveLock ( )
94
93
private let transform : Transform
95
94
private var activePublisher : NewPublisher ?
0 commit comments