Commit ecc84cce1dbb0fe84c3c29deaa3e1254b7dc6afa
filter when you do a full-scan
Dominic Tarr committed on 11/29/2016, 4:00:55 PMParent: 7af990ae7724e32491ab9490d20cc7b94907c514
Files changed
index.js | changed |
index.js | ||
---|---|---|
@@ -50,13 +50,13 @@ | ||
50 | 50 … | else |
51 | 51 … | q = {} |
52 | 52 … | |
53 | 53 … | var index = select(indexes, q) |
54 | - | |
54 … | + var filter = isArray(opts.query) ? mfr(opts.query) : pull.through() | |
55 | 55 … | if(!index) |
56 | - return log.stream({ | |
56 … | + return pull(log.stream({ | |
57 | 57 … | values: true, seqs: false, live: opts.live, limit: opts.limit, reverse: opts.reverse |
58 | - }) | |
58 … | + }), filter) | |
59 | 59 … | |
60 | 60 … | var _opts = query(index, q) |
61 | 61 … | |
62 | 62 … | _opts.values = false |
@@ -73,9 +73,9 @@ | ||
73 | 73 … | pull.map(function (data) { |
74 | 74 … | if(data.sync) return data |
75 | 75 … | else return data.value |
76 | 76 … | }), |
77 | - isArray(opts.query) ? mfr(opts.query) : pull.through() | |
77 … | + filter | |
78 | 78 … | ) |
79 | 79 … | |
80 | 80 … | } |
81 | 81 … | |
@@ -84,4 +84,8 @@ | ||
84 | 84 … | } |
85 | 85 … | |
86 | 86 … | |
87 | 87 … | |
88 … | + | |
89 … | + | |
90 … | + | |
91 … | + |
Built with git-ssb-web