Skip to content

Commit e29fd23

Browse files
committed
deploy: 8e103a5
1 parent 8a15f44 commit e29fd23

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

_modules/obelisk/asynchronous/consumer.html

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,16 @@ <h1>Source code for obelisk.asynchronous.consumer</h1><div class="highlight"><pr
203203
<span class="n">result_set</span><span class="o">.</span><span class="n">extend</span><span class="p">(</span><span class="n">result</span><span class="o">.</span><span class="n">items</span><span class="p">)</span>
204204
<span class="n">cursor</span> <span class="o">=</span> <span class="n">result</span><span class="o">.</span><span class="n">cursor</span>
205205

206+
<span class="k">if</span> <span class="n">limit</span> <span class="ow">and</span> <span class="nb">len</span><span class="p">(</span><span class="n">result_set</span><span class="p">)</span> <span class="o">&gt;=</span> <span class="n">limit</span><span class="p">:</span>
207+
<span class="w"> </span><span class="sd">&quot;&quot;&quot;On Obelisk HFS, limit is actually page size,</span>
208+
<span class="sd"> so continuing to read the cursor will result in a larger than desired</span>
209+
<span class="sd"> set of results.</span>
210+
211+
<span class="sd"> On the other hand, if the limit is very large,</span>
212+
<span class="sd"> we may need to iterate before we reach the desired limit after all.</span>
213+
<span class="sd"> &quot;&quot;&quot;</span>
214+
<span class="k">break</span>
215+
206216
<span class="k">return</span> <span class="n">result_set</span></div>
207217

208218

0 commit comments

Comments
 (0)