FRP - Functional Reactive Programming
20 likes4,557 views
関数リアクティブプログラミングを础苍诲谤辞颈诲や颈翱厂で使ってみた话
![(Objective-C)
[self.textField.rac_textSignal subscribeNext:^(id x){
NSLog(@"New value: %@", x);
} error:^(NSError *error){
NSLog(@"Error: %@", error);
} completed:^{
NSLog(@"Completed.");
}];](https://image.slidesharecdn.com/frp-functionalreactiveprogramming-140802084436-phpapp01/85/FRP-Functional-Reactive-Programming-11-320.jpg)
![Objective-C
[[[[[[[self.textField rac_textSignal]
filter:^BOOL(NSString *text) {
// 入力値をチェックして
@strongify(self)
return [self isValidText:text];
}]
throttle:0.5] // 500ミリ秒以内
flattenMap:^RACStream*(NSString *text) {
// 入力値をサーバーに送信
@strongify(self)
return [self signalForSendText:text];
}]
flattenMap:^RACStream*(NSDictionary *jsonResponse) {
// レスポンスの値を使って再度サーバーからデータ取得
@strongify(self)
return [self signalForResult:jsonResponse[@"result"]]
}]
deliverOn:[RACScheduler mainThreadScheduler]] // UIスレッドで
subscribeNext:^(NSDictionary *jsonRespoonse) {
// UIを更新
} error:^(NSError *error) {
NSLog(@"An error occurred: %@", error);
}];](https://image.slidesharecdn.com/frp-functionalreactiveprogramming-140802084436-phpapp01/85/FRP-Functional-Reactive-Programming-20-320.jpg)
More Related Content
Viewers also liked (15)
Similar to FRP - Functional Reactive Programming (17)
Recently uploaded (15)
FRP - Functional Reactive Programming
- 2. いいか?みんな (?д? ) (| y |) 関数型プログラミングの要素をリアクティブプログラミングに合わせると 関数型 (?д?) リアクティブ ＼／| y |＼／ FRPになるのだ ( ?д?) FRP (＼／＼／
- 3. (reactive) ( ) ( ) (behavior)
- 5. Java Objective-C FRP RxJava compile 'com.netflix.rxjava:rxjava-core:+' ReactiveCocoa pod 'ReactiveCocoa'
- 7. ( ) Pull java.lang.Iterable, RACSequence(ReactiveCocoa) Push rx.Observable(RxJava), RACSignal(ReactiveCocoa) Push
- 10. (Java) ViewObservable.input(mEditText, false) .subscribe(new Action1<String>() { @Override public void call(String s) { Log.d("LOG", "New value: " + s); } }, new Action1<Throwable>() { @Override public void call(Throwable t) { Log.d("LOG", "Error: " + t.getMessage()); } }, new Action0() { Override public void call() { Log.d("LOG", "Completed."); } });
- 11. (Objective-C) [self.textField.rac_textSignal subscribeNext:^(id x){ NSLog(@"New value: %@", x); } error:^(NSError *error){ NSLog(@"Error: %@", error); } completed:^{ NSLog(@"Completed."); }];
- 12. FRP KVO UI
- 14. Transformation map() / map: flatMap() / flattenMap:
- 15. Filtering filter() / filter: skip() / skip: throttleWithTimeout() / throttle:
- 16. Combining merge() / merge: zip() / zip:reduce:
- 17. Injection doOnEach() / doNext: doOnCompleted() / doCompleted: doOnError() / doError:
- 19. Java 8 ViewObservable.input(mEditText, false) .filter(text -> { // 入力値をチェックして return isValidText(text); }) .throttleWithTimeout(500, TimeUnit.MILLISECONDS) // 500ミリ秒以内 .flatMap(text -> { // 入力値をサーバーに送信 return sendTextObservable(text); }) .flatMap(jsonResponse -> { // レスポンスの値を使って再度サーバーからデータ取得 return resultObservable(jsonResponse.get("result")); }) .observeOn(AndroidSchedulers.mainThread()) // UIスレッドで .subscribe(jsonResponse -> { // UIを更新 }, throwable -> { Log.d("LOG", "An error occurred: " + throwable.getMessage()); });
- 20. Objective-C [[[[[[[self.textField rac_textSignal] filter:^BOOL(NSString *text) { // 入力値をチェックして @strongify(self) return [self isValidText:text]; }] throttle:0.5] // 500ミリ秒以内 flattenMap:^RACStream*(NSString *text) { // 入力値をサーバーに送信 @strongify(self) return [self signalForSendText:text]; }] flattenMap:^RACStream*(NSDictionary *jsonResponse) { // レスポンスの値を使って再度サーバーからデータ取得 @strongify(self) return [self signalForResult:jsonResponse[@"result"]] }] deliverOn:[RACScheduler mainThreadScheduler]] // UIスレッドで subscribeNext:^(NSDictionary *jsonRespoonse) { // UIを更新 } error:^(NSError *error) { NSLog(@"An error occurred: %@", error); }];
- 21. FRP GUI UI Push
- 24. Non-FRP UI
- 25. FRP
- 26. iOS Android Java Java8 (+ Retrolambda) Objective-C Groovy Swift
- 27. THE END