Download as PDF, PPTX
![Imperative let array = [0, 1, 2, 3, 4, 5] var evenNumbers = [Int]() for element in array { if element % 2 == 0 { evenNumbers.append(element) } } @EliSawic](https://image.slidesharecdn.com/introductiontofrp19-161120213443/75/Introduction-To-Functional-Reactive-Programming-Poznan-20-2048.jpg)
![Declarative let array = [0, 1, 2, 3, 4, 5] let evenNumbers = array.filter { $0 % 2 == 0 } @EliSawic](https://image.slidesharecdn.com/introductiontofrp19-161120213443/75/Introduction-To-Functional-Reactive-Programming-Poznan-22-2048.jpg)
![Is mail valid? let isValidMail = mailSignal.map { (mail) -> Bool in let emailRegEx = "[A-Z0-9a-z._%+-]+@[A-Za-z0-9.-]+.[A-Za-z]{2,}" let emailTest = NSPredicate(format:"SELF MATCHES %@", emailRegEx) return emailTest.evaluateWithObject(mail) } @EliSawic](https://image.slidesharecdn.com/introductiontofrp19-161120213443/75/Introduction-To-Functional-Reactive-Programming-Poznan-77-2048.jpg)
Introduction To Functional Reactive Programming Poznan
- 1.
- 2. About me Eliasz Sawicki Blog:www.eliaszsawicki.com Twitter: @EliSawic @EliSawic
- 3. Agenda • What isfunctional reactive programming? • Working with streams • ReactiveCocoa - Thinking in signals • Example @EliSawic
- 4.
- 5. Wikipedia Functional reactive programming(FRP) is a programming paradigm for reactive programming (asynchronous dataflow programming) using the building blocks of functional programming (e.g. map, reduce, filter). @EliSawic
- 6.
- 7.
- 8.
- 9.
- 10.
- 11.
- 12. A person class Person{ let name: String let phoneNumber: String init(name: String, phoneNumber: String) { self.name = name self.phoneNumber = phoneNumber } } class MobilePhone { func call(person: Person) -> Bool { // implementation } } @EliSawic
- 13. Mutable let mobilePhone =MobilePhone() let john = Person(name: "John", phoneNumber: "123456789") func makeAPhoneCall(device: Phone, person: Person, countryCode: String) -> Bool { person.phoneNumber = countryCode + person.phoneNumber let success = device.call(person) return success } makeAPhoneCall(device: mobilePhone, person: john, countryCode: "+48") // true makeAPhoneCall(device: mobilePhone, person: john, countryCode: "+48") // false makeAPhoneCall(device: mobilePhone, person: john, countryCode: "+48") // false @EliSawic
- 14. Immutable let mobilePhone =MobilePhone() let john = Person(name: "John", phoneNumber: "123456789") func makeAPhoneCall(device: Phone, person: Person, countryCode: String) -> Bool { let prefixedPhoneNumber = countryCode + person.phoneNumber let newPerson = Person(name: person.name, phoneNumber: prefixedPhoneNumber) let success = device.call(newPerson) return success } makeAPhoneCall(device: mobilePhone, person: john, countryCode: "+48") // true makeAPhoneCall(device: mobilePhone, person: john, countryCode: "+48") // true makeAPhoneCall(device: mobilePhone, person: john, countryCode: "+48") // true @EliSawic
- 15.
- 16. Stateful var value =0 func increment() -> Int { value += 1 return value } @EliSawic
- 17. Stateless func increment(value: Int)-> Int { return value + 1 } @EliSawic
- 18.
- 19.
- 20. Imperative let array =[0, 1, 2, 3, 4, 5] var evenNumbers = [Int]() for element in array { if element % 2 == 0 { evenNumbers.append(element) } } @EliSawic
- 21.
- 22. Declarative let array =[0, 1, 2, 3, 4, 5] let evenNumbers = array.filter { $0 % 2 == 0 } @EliSawic
- 23.
- 24.
- 25.
- 26.
- 27.
- 28.
- 29.
- 30.
- 31.
- 32.
- 33.
- 34.
- 35.
- 36.
- 37.
- 38. What is asignal? @EliSawic
- 39. This presentation isa signal @EliSawic
- 40.
- 41. No random accessto events @EliSawic
- 42.
- 43. If you don'tlisten, it's gone @EliSawic
- 44. Observing does not triggerside effects @EliSawic
- 45.
- 46. Event enum Quality { caseGreat case Average case Worst } struct Idea { var content: String var quality: Quality } @EliSawic
- 47.
- 48. Terminating • Completed • Failed •Interrupted (Reactive Cocoa) @EliSawic
- 49. Presentation let (presentation, presentationObserver)= Signal<Idea, NoError>.pipe() let content = "This presentation is a signal" let idea = Idea(content: content, quality: .Great) presentationObserver.send(value: idea) @EliSawic
- 50. Observing presentation.observeValues { ideain remember(idea: idea) } presentation.observeCompleted { print("Finally...") } presentationObserver.send(value: idea) presentationObserver.sendCompleted() @EliSawic
- 51. Only great ideas letgreatIdeas = presentation.filter { $0.quality == .Great } greatIdeas.observeValues { (greatIdea) in remember(idea: greatIdea) } presentationObserver.send(value: idea) presentationObserver.sendCompleted() @EliSawic
- 52. Positive listener let greatPresentation= presentation.map { idea -> Idea in var greatIdea = idea greatIdea.quality = .Great return greatIdea } @EliSawic
- 53. Count worst ideas letworstIdeas = greatPresentation.filter { $0.quality == .Worst } let numberOfWorstIdeas = worstIdeas.reduce(0) { (sum, idea) -> Int in return sum + 1 } numberOfWorstIdeas.observeValues { (numberOfWorstIdeas) in print("Number of worst ideas: (numberOfWorstIdeas)") } presentationObserver.send(value: idea) presentationObserver.sendCompleted() @EliSawic
- 54. Signal's lifetime • Passesany number of Next events • "Dies" when terminating event • Any new observer will receive Interrupted event @EliSawic
- 55.
- 56.
- 57.
- 58.
- 59. Does not startit's work if not asked @EliSawic
- 60. Run presentation func runPresentation()-> SignalProducer<Idea, NoError> { return SignalProducer { observer, _ in observer.send(value: idea1) observer.send(value: idea2) ... observer.sendCompleted() } } @EliSawic
- 61. Work with presentation runPresentation().startWithSignal{ (signal, _) in signal.observeValues({ idea in print(idea) }) signal.observeCompleted { print("Finally...") } } @EliSawic
- 62.
- 63.
- 64. Mutable Property let firstSlide= Slide(number: 1) let slide = MutableProperty<Slide>(firstSlide) slide.producer.startWithNext { (text) in print(text) } slide.value = Slide(number: 2) @EliSawic
- 65.
- 66. Binding example let slideNumber= MutableProperty<Int>(0) let (signal, _) = Signal<Slide, NoError>.pipe() slideNumber <~ signal.map { return $0.number } label.reactive.text <~ signal.map { return "Slide number ($0.number)" } @EliSawic
- 67.
- 68. Know where youare signal.observe(on: QueueScheduler.main).observeValues { idea in print("Performing UI updates") } producer.start(on: backgroundQueue).startWithValues { values in print("Starting task") } @EliSawic
- 69.
- 70.
- 71. Free your memory letdisposablesBag = CompositeDisposable() disposablesBag += signal.observeValues { value in ... } disposablesBag += producePresentation().startWithValues { (value) in ... } disposablesBag.dispose() @EliSawic
- 72.
- 73.
- 74. How does itwork? @EliSawic
- 75. Is name valid? letisValidName = nameSignal.map { (name) -> Bool in return input.characters.count > 2 } @EliSawic
- 76. Is surname valid? letisValidSurname = nameSignal.map { (name) -> Bool in return input.characters.count > 2 } @EliSawic
- 77. Is mail valid? letisValidMail = mailSignal.map { (mail) -> Bool in let emailRegEx = "[A-Z0-9a-z._%+-]+@[A-Za-z0-9.-]+.[A-Za-z]{2,}" let emailTest = NSPredicate(format:"SELF MATCHES %@", emailRegEx) return emailTest.evaluateWithObject(mail) } @EliSawic
- 78. Combine Latest let formData= combineLatest(isValidName, isValidSurname, isValidMail) @EliSawic
- 79. Is form valid? letisValidForm = MutableProperty<Bool>(false) isValidForm <~ formData.map { (isValidName, isValidSurname, isValidMail) -> Bool in return isValidMail && isValidSurname && isValidMail } @EliSawic
- 80. Button state let producer= isValidForm.producer.skipRepeats() producer.startWithNext { isValid in updateButtonWith(state: isValid) } @EliSawic
- 81.
- 82. Thank you foryour attention! sendCompleted() @EliSawic