Difference between revisions of "Reactive functional programming"
From Wiki2
| Line 1: | Line 1: | ||
==rxjs== | ==rxjs== | ||
internally: | |||
function map(fn) { | |||
var source=this | |||
result = Rx.Observable.create(function subscribe(observer){ | |||
source.subscribe( | |||
function(x) {observer.next(fn(x));}, | |||
function(err){ oberver.error(err));}, | |||
function() {observer.complete();} | |||
) | |||
}) | |||
} | |||
Rx.Observable.prototype.map = map | |||
===operators=== | ===operators=== | ||
Rx.Observable.of(4,5,6,7,8) | Rx.Observable.of(4,5,6,7,8) | ||
(45678|) | (45678|) | ||
Rx.Observable.interval(500).take(4) | Rx.Observable.interval(500).take(4), a kind of filter, also: first, takeLast, last, skip, skipLast | ||
---0---1---2---3| | ---0---1---2---3| | ||
[4,5,6,7].do(x=>console.log('dog is '+x)) //doesn't touch the Observable, passes it through | |||
Rx.Observable.interval(500).take(4) | |||
---0---1---2---3| foo | |||
(8,9,10,11|) more | |||
foo.concat(more) | |||
---0---1---2---3(8,9,10,11|) | |||
Revision as of 08:41, 25 May 2016
rxjs
internally:
function map(fn) { var source=this result = Rx.Observable.create(function subscribe(observer){ source.subscribe( function(x) {observer.next(fn(x));}, function(err){ oberver.error(err));}, function() {observer.complete();} ) }) } Rx.Observable.prototype.map = map
operators
Rx.Observable.of(4,5,6,7,8) (45678|)
Rx.Observable.interval(500).take(4), a kind of filter, also: first, takeLast, last, skip, skipLast ---0---1---2---3|
[4,5,6,7].do(x=>console.log('dog is '+x)) //doesn't touch the Observable, passes it through
Rx.Observable.interval(500).take(4) ---0---1---2---3| foo (8,9,10,11|) more foo.concat(more) ---0---1---2---3(8,9,10,11|)
