Reactive thinking in Swift

presented at CA.swift #01
01 DEC. 2016

Transcript

1. Reactive thinking in Swift 2016/12/01 CA.swift Ryo Aoyama / ra1028 #ca_swift
3. ແྉͰߴը࣭ͳੜ์ૹಈըΛݟ์୊ ੜ์ૹ഑৴ϓϥοτϑΥʔϜαʔϏε
4. FRP Functional Reactive Programming
5. RxSwift RxCocoa ReactiveSwift ReactiveCocoa
6. ɾඇಉظσʔλϑϩʔΛந৅Խ͠ɺ ౷ҰతͳΠϯλʔϑΣʔεͰ ѻ͏͜ͱ͕Ͱ͖Δ ɾঢ়ଶ؅ཧΛݮΒͤΔ ɾએݴతͳهड़͕Ͱ͖Δ Why use…?
7. ɾDelegate methods ɾCallback blocks ɾNotifications ɾControl actions ɾResponder chain events ɾKey-value observing (KVO) ɾFutures and promises
8. Event Stream Observable<T> Signal<T, E> SignalProducer<T, E>
9. Event Stream?
10. Event Stream = Water pipe
11. Event Observable Signal SignalProducer Observe
12. Transforming
13. Map Next(x) Next(x * 10) Eventͷ࣋ͭ஋Λม׵͢Δ map
14. FlatMap Next(•) Next(▪) 2ͭͷΠϕϯτετϦʔϜ Λ1ͭʹฏୱԽ͢Δ flatMap
15. Filtering
16. Filter ৚݅ʹ߹க͢Δ஋͚ͩΛ ड͚औΔ filter Next(5)
17. Combining
18. Merge ෳ਺ͷΠϕϯτετϦʔϜ ͷ஋ΛҰຊʹͯ͠ड͚औΔ merge
19. Sample with RxSwift UISegmentedControl, UITextField ͦΕͧΕͷΠϕϯτͰAPIϦΫΤετΛߦ͍ɺ ͦͷϨεϙϯεʹԠͯ͡UITableViewΛදࣔߋ৽͢Δɻ
20. without RxSwift
21. final class NonRxViewController: UIViewController { @IBOutlet fileprivate weak var segmentedControl: UISegmentedControl! @IBOutlet fileprivate weak var textField: UITextField! @IBOutlet fileprivate weak var tableView: UITableView! fileprivate var items = [Item]() override func viewDidLoad() { super.viewDidLoad() tableView.register(SampleCell.self, forCellReuseIdentifier: "SampleCell") tableView.delegate = self tableView.dataSource = self } }
22. private extension NonRxViewController { @IBAction func segmentedControlChanged(_ sender: UISegmentedControl) { getItemsAndReload() } @IBAction func textFieldChanged(_ sender: UITextField) { getItemsAndReload() } func getItemsAndReload() { let text = textField.text ?? "" let index = segmentedControl.selectedSegmentIndex Api.getItems(segmentIndex: index, text: text) { [weak self] items in let reload = { self?.items = items self?.tableView.reloadData() } if Thread.isMainThread { reload() } else { DispatchQueue.main.async(execute: reload) } } } }
23. extension NonRxViewController: UITableViewDelegate, UITableViewDataSource { func numberOfSections(in tableView: UITableView) -> Int { return 1 } func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int { return items.count } func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell { let cell = tableView.dequeueReusableCell(withIdentifier: "SampleCell", for: indexPath) as! SampleCell let item = items[indexPath.item] cell.configure(with: item) return cell } }
24. ɾMutableͳม਺(ঢ়ଶ) ɾεϨου؅ཧ ɾॲཧͷϑϩʔ͕ෳࡶ ɾ֦ு͕೉͍͠ ɾControl Actions ɾCallback blocks ɾDelegate methods
25. with RxSwift
26. final class RxViewController: UIViewController { @IBOutlet private weak var segmentedControl: UISegmentedControl! @IBOutlet private weak var textField: UITextField! @IBOutlet private weak var tableView: UITableView! private let disposeBag = DisposeBag() override func viewDidLoad() { super.viewDidLoad() tableView.register(SampleCell.self, forCellReuseIdentifier: "SampleCell") Observable.combineLatest( segmentedControl.rx.value, textField.rx.text.orEmpty.distinctUntilChanged()) { ($0, $1) } .skip(1) .flatMap(Api.getItems) .asDriver(onErrorJustReturn: []) .drive(tableView.rx.items(cellIdentifier: "SampleCell", cellType: SampleCell.self)) { _, item, cell in cell.configure(with: item) } .addDisposableTo(disposeBag) } }
27. ɾMutableͳม਺(ঢ়ଶ) ɾεϨου؅ཧ ɾॲཧͷϑϩʔ͕ෳࡶ ɾ֦ு͕೉͍͠ ɾControl Actions ɾCallback blocks ɾDelegate methods
28. Hot & Cold
29. Hot Observable Signal ɾߪಡऀͷ༗ແʹؔΘΒͣΠϕϯτ͕ྲྀΕΔ ɾෳ਺ߪಡ͞ΕΔͱετϦʔϜ͕෼ذ͢Δ
30. Subscribe Subscribe Subscribe Subscribe Hot
31. Hot let subject = PublishSubject<Int>() let observer = subject.asObserver() let randomInt = { Int(arc4random_uniform(100)) } // PublishSubjectΛasObservable()͢ΔͱHot ObservableʹͳΔ let hot = subject.asObservable() hot.subscribe(onNext: { print("Hot 1: \($0)") }) hot.subscribe(onNext: { print("Hot 2: \($0)") }) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") ----- 1: 20 2: 20 ----- 1: 30 2: 30 ----- 1: 93 2: 93 ----- ग़ྗ ෼ذͤͨ̎ͭ͞ͷߪಡͰ ஋͕ڞ༗͞Ε͍ͯΔࣄ͕Θ͔Δ
32. Observable SignalProducer Cold ɾߪಡ͢Δ·Ͱಈ࡞͠ͳ͍ ɾߪಡ͞Εͨ਺͚ͩετϦʔϜ͕࡞ΒΕΔ
33. Subscribe Subscribe Subscribe Subscribe Cold
34. Cold // RxSwiftͰ͸Hot ObservableΛmap͢ΔͱCold ObservableʹͳΔ let cold = hot.map { $0 + randomInt() } cold.subscribe(onNext: { print("Cold 1: \($0)") }) cold.subscribe(onNext: { print("Cold 2: \($0)") }) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") ------ 1: 182 2: 117 ------ 1: 84 2: 139 ------ 1: 106 2: 64 ------ ग़ྗ ̎ͭͷߪಡͰผʑͷ ετϦʔϜʹͳ͍ͬͯΔ
35. ColdͰॏ͍ॲཧ΍APIϦΫΤετΛ͍ͯ͠Δͱ…
36. let cold = hot.map { i -> Int in sleep(1) // <- ॏ͍ॲཧ return i } cold.subscribe(onNext: { print("Cold 1: \($0), seconds: \(currentTimeSeconds())") }) cold.subscribe(onNext: { print("Cold 2: \($0), seconds: \(currentTimeSeconds())") }) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") ----------------------- Cold 1: 21, seconds: 49 Cold 2: 21, seconds: 50 ----------------------- Cold 1: 62, seconds: 51 Cold 2: 62, seconds: 52 ----------------------- Cold 1: 65, seconds: 53 Cold 2: 65, seconds: 54 ----------------------- ग़ྗ ੩తͳ஋Λฦ͍ͯͯ͠ݟ্͔͚஋͕ڞ༗Ͱ͖͍ͯͯ΋ɺ ॲཧ͸ߪಡ͍ͯ͠Δ͚ͩߦΘΕ͍ͯΔ Cold
37. Cold -> Hot
38. Subscribe Subscribe Subscribe Subscribe Cold -> Hot
39. Subscribe Subscribe Subscribe Subscribe Cold -> Hot
40. // Cold ObervableΛshareReplay͢Δ͜ͱͰHot ObservableʹͳΔ let coldToHot = cold.shareReplay(1) coldToHot.subscribe(onNext: { print("ColdToHot 1: \($0)") }) coldToHot.subscribe(onNext: { print("ColdToHot 2: \($0)") }) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") ----- 1: 32 2: 32 ----- 1: 54 2: 54 ----- 1: 144 2: 144 ----- ग़ྗ ஋Λڞ༗͢ΔΑ͏ʹͳͬͨ Cold -> Hot
41. Hotม׵͍ͯ͠Ε͹ɺColdͰॏ͍ॲཧ͕ߦΘΕͯ΋…
42. let cold = hot.map { i -> Int in sleep(1) // <- ॏ͍ॲཧ return i } .shareReplay(1) cold.subscribe(onNext: { print("Cold 1: \($0), seconds: \(currentTimeSeconds())") }) cold.subscribe(onNext: { print("Cold 2: \($0), seconds: \(currentTimeSeconds())") }) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") observer.onNext(randomInt()) print("-----") ---------------------- Cold 1: 6, seconds: 7 Cold 2: 6, seconds: 7 ---------------------- Cold 1: 74, seconds: 8 Cold 2: 74, seconds: 8 ---------------------- Cold 1: 77, seconds: 9 Cold 2: 77, seconds: 9 ---------------------- ग़ྗ ෳ਺ߪಡ͍ͯͯ͠΋ ॲཧ͕ߦΘΕΔͷ͸Ұճ͚ͩ Cold -> Hot
43. ·ͱΊ
44. Event Stream ઃܭͷΠϯλʔϑΣʔε͕౷ҰԽɻ ࿈ଓతͳ஋ΛͲ͏ѻ͏͔͚ͩΛએݴతʹهड़͠ɺ ετϦʔϜಉ࢜Λ઀ଓ͢Δɻ = ඞવతʹMutableͳঢ়ଶ؅ཧ͸ݮΔɻ ίʔυྔͷ࡟ݮ͕࠷େͷར఺Ͱ͸ͳ͍ɻ
45. Hot & Cold Hot or ColdͰετϦʔϜ઀ଓͷ͞Εํ͕ҟͳΔɻ ҙࣝ͠ͳ͍ͱϦιʔεͷແବɾҙਤ͠ͳ͍ڍಈɾόά ͷՄೳੑ͕͋Δɻ RxSwiftͰ͸҉໧తɻ ReactiveSwiftͰ͸໌ࣔతɻ
46. ͝੩ௌ͋Γ͕ͱ͏͍͟͝·ͨ͠