Comparing version 0.2.0 to 0.2.1
{ | ||
"name": "flyd", | ||
"version": "0.2.0", | ||
"version": "0.2.1", | ||
"description": "The less is more, modular, functional reactive programming library", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
@@ -220,9 +220,7 @@ # Flyd | ||
var urls = flyd.stream('/something.json'); | ||
var responses = flyd.stream(function() { | ||
return requestPromise(urls()); | ||
}); | ||
flyd.combine(function(responses) { | ||
var responses = flyd.stream(requestPromise(urls())); | ||
flyd.on(function(responses) { | ||
console.log('Received response!'); | ||
console.log(responses()); | ||
}, [responses]); | ||
}, responses); | ||
``` | ||
@@ -307,3 +305,3 @@ | ||
var killer = flyd.stream(); | ||
var square = flyd.endsOn(flyd.merge(number.end, killer), flyd.stream(function(number) { | ||
var square = flyd.endsOn(flyd.merge(number.end, killer), flyd.combine(function(number) { | ||
return number() * number(); | ||
@@ -389,3 +387,3 @@ }, [number])); | ||
var s = flyd.stream(); | ||
var hasItems = flyd.immediate(flyd.stream(function(s) { | ||
var hasItems = flyd.immediate(flyd.combine(function(s) { | ||
return s() !== undefined && s().length > 0; | ||
@@ -634,2 +632,3 @@ }, [s]); | ||
* [flyd/module/scanmerge](module/scanmerge) – Merge and scan several streams into one. | ||
* [flyd/module/mergeall](module/mergeall) – Merge merge a list of streams. | ||
* [flyd/module/takeuntil](module/takeuntil) – Emit values from a stream until a second stream emits a value. | ||
@@ -636,0 +635,0 @@ * [flyd/module/forwardto](module/forwardto) – Create a new stream that passes all values through a function and forwards them to a target stream. |
325322
93
8518
700