Przekształcanie i łączenie strumieni
Używanie flatMap, merge, combineLatest i zip.
Przekształcanie i łączenie strumieni to bezpłatna lekcja Swift Academy na CoddyKit. To lekcja 1 z 4. Możesz przeczytać całą lekcję poniżej za darmo — a potem ćwiczyć ją interaktywnie w przeglądarce z wbudowanym edytorem kodu i tutorem AI dostępnym 24/7. To część ścieżki edukacyjnej Swift Academy, a Twój postęp synchronizuje się między webem a aplikacją CoddyKit. Kurs Swift Academy zawiera 4 lekcji w sumie.
Praca ze strumieniami
W Combine publisher emituje w czasie strumień wartości. Prawdziwa siła tego rozwiązania wynika z operatorów, które przekształcają te strumienie i łączą je w nowe.
Ta lekcja omawia najważniejsze operatory przekształcania i łączenia: flatMap, merge, combineLatest oraz zip.
map a flatMap
map przekształca każdą wartość w inną wartość. flatMap idzie o krok dalej — przekształca każdą wartość w nowy publisher i spłaszcza wyniki do jednego strumienia.
Używaj flatMap, gdy każde wejście powinno uruchomić kolejną operację asynchroniczną.
flatMap w działaniu
Strumień identyfikatorów użytkowników jest tutaj mapowany na strumień żądań sieciowych, a następnie spłaszczany do jednego strumienia użytkowników.
userIdPublisher
.flatMap { id in
apiClient.fetchUser(id: id)
}
.sink { user in
print("Loaded", user.name)
}
.store(in: &cancellables)Kontrolowanie współbieżności flatMap
Domyślnie flatMap subskrybuje wszystkie wewnętrzne publishery jednocześnie. Możesz ograniczyć współbieżność za pomocą maxPublishers, aby nie przeciążyć serwera.
idsPublisher
.flatMap(maxPublishers: .max(2)) { id in
apiClient.fetchUser(id: id)
}
.sink { print($0) }
.store(in: &cancellables)merge
merge przeplata wartości z wielu publisherów tego samego typu w jednym strumieniu, emitując każdą wartość natychmiast po jej nadejściu.
let combined = buttonTapA
.merge(with: buttonTapB)
combined
.sink { print("A tap from either button") }
.store(in: &cancellables)combineLatest
combineLatest emituje wartość za każdym razem, gdy emituje dowolny wejściowy publisher, łącząc najnowszą wartość z każdego z nich. Doskonale nadaje się do walidacji formularzy, w których trzeba uwzględnić kilka pól.
usernamePublisher
.combineLatest(passwordPublisher)
.map { name, pass in
!name.isEmpty && pass.count >= 8
}
.sink { isValid in
print("Form valid:", isValid)
}
.store(in: &cancellables)Działanie combineLatest
Uwaga: combineLatest niczego nie emituje, dopóki każde wejście nie wygeneruje co najmniej jednej wartości. Później każda nowa emisja z dowolnego wejścia wywołuje połączone wyjście zawierające najnowsze wartości pozostałych wejść.
zip
zip łączy wartości według indeksu: pierwszą wartość A z pierwszą wartością B, drugą z drugą i tak dalej. Czeka, aż obie strony będą miały wartość na danej pozycji.
let names = ["Ann", "Bob", "Cy"].publisher
let ages = [30, 25, 41].publisher
names
.zip(ages)
.sink { name, age in
print(name, "is", age)
}
.store(in: &cancellables)combineLatest a zip
Te dwa operatory łatwo pomylić:
- combineLatest — reaguje na każdą emisję i używa najnowszej wartości z każdego wejścia
- zip — reaguje tylko na dopasowane pary według indeksu
Używaj combineLatest dla bieżącego stanu, a zip, aby dopasowywać równoległe wyniki jeden do jednego.
Łączenie na potrzeby pracy równoległej
zip sprawdza się doskonale podczas równoległego wykonywania niezależnych żądań i oczekiwania na wszystkie z nich.
fetchProfile
.zip(fetchSettings)
.sink { profile, settings in
print("Both loaded")
}
.store(in: &cancellables)Łączenie operatorów
Rzeczywiste potoki łączą kilka operatorów, aby deklaratywnie wyrażać złożone przepływy asynchroniczne.
searchTextPublisher
.removeDuplicates()
.flatMap { query in
apiClient.search(query)
}
.map { results in
results.prefix(10)
}
.sink { print($0) }
.store(in: &cancellables)Szybki test
Sprawdź swoją wiedzę na temat operatorów.
Podsumowanie
Poznałeś(-aś) sposoby przekształcania i łączenia strumieni:
- flatMap — wartość zamieniana na publisher i spłaszczana
- merge — przeplatanie strumieni tego samego typu
- combineLatest — najnowsza wartość z każdego wejścia, emisja przy każdej zmianie
- zip — pary dopasowane według indeksu
Te operatory pozwalają deklaratywnie komponować złożoną logikę asynchroniczną.
Często zadawane pytania
Czy lekcja „Przekształcanie i łączenie strumieni” jest bezpłatna?
Tak — pełny tekst „Przekształcanie i łączenie strumieni” jest dostępny za darmo tutaj w sieci. Aby ćwiczyć ją interaktywnie (wbudowany edytor kodu i tutor AI dostępny 24/7) i odblokować resztę kursu Swift Academy, przejdź na CoddyKit PRO. Kurs Swift Academy zawiera 4 lekcji w sumie.
Co nauczysz się w „Przekształcanie i łączenie strumieni”?
Używanie flatMap, merge, combineLatest i zip. Ćwiczysz Swift Academy z praktycznym kodem, który uruchamiasz bezpośrednio w przeglądarce, a tutor AI dostępny 24/7 odpowiada na Twoje pytania podczas pracy nad lekcją.
Czy potrzebuję doświadczenia, aby zacząć Swift Academy?
Nie wymagamy żadnego doświadczenia. Swift Academy w CoddyKit jest strukturyzowany dla początkujących i zaawansowanych użytkowników, więc możesz zacząć tutaj lub od początku i uczyć się w swoim tempie. To lekcja 1 z 4.
Ile czasu zajmuje lekcja „Przekształcanie i łączenie strumieni”?
Większość lekcji CoddyKit trwa około 5–10 minut. Każda lekcja to mały, interaktywny krok, dzięki czemu robisz systematyczne postępy i zawsze wracasz dokładnie do tego samego miejsca — na webie i w aplikacji.
Czy mogę pisać i uruchamiać kod w tej lekcji Swift Academy?
Tak. Każda lekcja Swift Academy zawiera wbudowany edytor kodu, więc piszesz i uruchamiasz prawdziwy kod bezpośrednio w przeglądarce i od razu otrzymujesz sprzężenie zwrotne od AI — bez konfiguracji na komputerze.
Wszystkie lekcje w tym kursie
- Przekształcanie i łączenie strumieni
- Harmonogramy i wątki
- Operatory obsługi błędów
- Niestandardowi publisherzy i subskrybenci