diff --git a/Sources/Request/Request/Request+Combine.swift b/Sources/Request/Request/Request+Combine.swift index 57a4f18..2443d76 100644 --- a/Sources/Request/Request/Request+Combine.swift +++ b/Sources/Request/Request/Request+Combine.swift @@ -45,13 +45,13 @@ extension AnyRequest: Publisher { public typealias UpdatePublisher = Publishers.FlatMap where Downstream: Publisher, Upstream: Publisher, Downstream.Failure == Error, Upstream.Failure == Error - func updatePublisher(publisher: T) -> UpdatePublisher { + public func updatePublisher(publisher: T) -> UpdatePublisher { publisher.flatMap { _ in self } } public typealias UpdateTimerPublisher = UpdatePublisher, Error>> - func updatePublisher(every seconds: TimeInterval) -> UpdateTimerPublisher { + public func updatePublisher(every seconds: TimeInterval) -> UpdateTimerPublisher { updatePublisher(publisher: Timer.publish(every: seconds, on: .main, in: .common) .autoconnect() .mapError { _ in RequestError(statusCode: -1, error: nil) })