From 3a1124f3ec637fcf9c6913d60107a89ed71e6dad Mon Sep 17 00:00:00 2001 From: eladzlot Date: Sun, 20 Nov 2016 14:13:35 +0200 Subject: [PATCH] simplify array operators in stream --- stream/stream.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/stream/stream.js b/stream/stream.js index f1cc33df..9a29ab02 100644 --- a/stream/stream.js +++ b/stream/stream.js @@ -44,7 +44,7 @@ function updateState(stream, value) { } function updateDependency(stream, mustSync) { var state = stream._state, parents = state.parents - if (parents.length > 0 && parents.filter(active).length === parents.length && (mustSync || parents.filter(changed).length > 0)) { + if (parents.length > 0 && parents.every(active) && (mustSync || parents.some(changed))) { var value = stream._state.derive() if (value === HALT) return false updateState(stream, value) @@ -56,7 +56,7 @@ function finalize(stream) { } function combine(fn, streams) { - if (streams.length > streams.filter(valid).length) throw new Error("Ensure that each item passed to m.prop.combine/m.prop.merge is a stream") + if (!streams.every(valid)) throw new Error("Ensure that each item passed to m.prop.combine/m.prop.merge is a stream") return initDependency(createStream(), streams, function() { return fn.apply(this, streams.concat([streams.filter(changed)])) })