@@ -28,7 +28,7 @@ public extension Publisher {
2828
2929@available ( OSX 10 . 15 , iOS 13 . 0 , tvOS 13 . 0 , watchOS 6 . 0 , * )
3030public 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 {
3232 public typealias Transform = ( Upstream . Output ) -> NewPublisher
3333 public typealias Output = NewPublisher . Output
3434 public typealias Failure = Upstream . Failure
@@ -88,8 +88,7 @@ private extension Publishers.ConcatMap {
8888// MARK: - Sink
8989@available ( OSX 10 . 15 , iOS 13 . 0 , tvOS 13 . 0 , watchOS 6 . 0 , * )
9090private 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 {
9392 private let lock = NSRecursiveLock ( )
9493 private let transform : Transform
9594 private var activePublisher : NewPublisher ?
0 commit comments