diff --git a/Sources/Operators/Internal/Timer.swift b/Sources/Operators/Internal/Timer.swift index 8856447..a405f9e 100644 --- a/Sources/Operators/Internal/Timer.swift +++ b/Sources/Operators/Internal/Timer.swift @@ -161,10 +161,10 @@ lock.cleanupLock() } - func addSubscriber(_ sub: S) + func addSubscriber(_ sub: T) where - S.Failure == Failure, - S.Input == Output + T.Failure == Failure, + T.Input == Output { lock.lock() subscribers.append(AnySubscriber(sub)) @@ -229,8 +229,8 @@ } } - internal func receive(subscriber: S) - where Failure == S.Failure, Output == S.Input { + internal func receive(subscriber: T) + where Failure == T.Failure, Output == T.Input { routingSubscription.addSubscriber(subscriber) }