Integrate Combine Into an App
About this episode
Leave a rating/review
See forum comments
Mark complete
Next episode: 05. Use @ObservedObject to Monitor State
Heads up... You’re accessing parts of this content for free, with some sections shown as text.
Heads up... You’re accessing parts of this content for free, with some sections shown as text.
Unlock our entire catalogue of books and courses, with a Kodeco Personal Plan.
Unlock now
In the last episode, we made our own custom publishers that, in the end, started with a publisher (in this case a dataTaskPublisher from URLSession), and we performed some operations on that publisher, the last of which was erasing the type signature to AnyPublisher. This takes advantage of the fact that Operators are both Publishers and Subscribers.
private let jokesService: JokeServiceDataPublisher
private let translationService: TranslationServiceDataPublisher
public init(jokesService: JokeServiceDataPublisher = JokesService(),
translationService: TranslationServiceDataPublisher = TranslationService()) {
self.jokesService = jokesService
self.translationService = translationService
}
$joke
.map { _ in false }
.assign(to: \.fetching, on: self)
.store(in: &subscriptions)
public func fetchJoke() {
// 1
fetching = true
// 2
jokeSubscriptions = []
jokesService.publisher()
.retry(1)
.decode(type: Joke.self, decoder: Self.decoder)
.replaceError(with: Joke.error)
.receive(on: DispatchQueue.main)
.handleEvents(receiveOutput: { [unowned self] in
self.joke = $0
})
.filter { $0 != Joke.error }
.flatMap { [unowned self] joke in
self.fetchTranslation(for: joke, to: "es")
}
.receive(on: DispatchQueue.main)
.assign(to: \.joke, on: self)
.store(in: &jokeSubscriptions)
}
func fetchTranslation(for joke: Joke, to languageCode: String)
-> AnyPublisher<Joke, Never> {
guard joke.languageCode != languageCode else {
return Just(joke).eraseToAnyPublisher()
}
return translationService.publisher(for: joke, to: languageCode)
.retry(1)
.decode(type: TranslationResponse.self, decoder: Self.decoder)
.compactMap { $0.translations.first }
.map {
Joke(id: joke.id,
value: joke.value,
categories: joke.categories,
languageCode: languageCode,
translationLanguageCode: languageCode,
translatedValue: $0)
}
// 5
.replaceError(with: Joke.error)
.eraseToAnyPublisher()
}