Commit 5200adabbef51ad8ccb3c18fc1b9a0ce470f4a70
use pull.take instead of limit to handle variance in query filtering
Matt McKegg committed on 6/14/2017, 3:31:33 AMParent: 2dfaba9cc2afad28c3417db1c1074a5f2fbeb095
Files changed
lib/flumeview-links-raw.js | changed |
lib/flumeview-links-raw.js | |||
---|---|---|---|
@@ -76,21 +76,20 @@ | |||
76 | 76 … | }) | |
77 | 77 … | return emit | |
78 | 78 … | }) | |
79 | 79 … | ) | |
80 … | + | ||
80 | 81 … | var _opts = query(index, q) | |
81 | 82 … | ||
82 | - | ||
83 | 83 … | _opts.values = false | |
84 | 84 … | _opts.keys = true | |
85 | 85 … | ||
86 | 86 … | _opts.reverse = !!opts.reverse | |
87 | 87 … | _opts.live = opts.live | |
88 | 88 … | _opts.old = opts.old | |
89 | 89 … | _opts.sync = opts.sync | |
90 | - _opts.limit = opts.limit | ||
91 | 90 … | ||
92 | - return pull( | ||
91 … | + var stream = pull( | ||
93 | 92 … | read(_opts), | |
94 | 93 … | pull.map(function (data) { | |
95 | 94 … | if(data.sync) return data | |
96 | 95 … | var o = data.value | |
@@ -99,8 +98,17 @@ | |||
99 | 98 … | return o | |
100 | 99 … | }), | |
101 | 100 … | isArray(opts.query) ? mfr(opts.query) : pull.through() | |
102 | 101 … | ) | |
102 … | + | ||
103 … | + if (typeof opts.limit === 'number') { | ||
104 … | + return pull( | ||
105 … | + stream, | ||
106 … | + pull.take(opts.limit) | ||
107 … | + ) | ||
108 … | + } else { | ||
109 … | + return stream | ||
110 … | + } | ||
103 | 111 … | } | |
104 | 112 … | return index | |
105 | 113 … | } | |
106 | 114 … | } |
Built with git-ssb-web