|
3 | 3 | <head>
|
4 | 4 | <meta charset="utf-8" />
|
5 | 5 | <meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
6 |
| - <title>stream2py.stream_buffer — stream2py 1.0.33 documentation</title><link rel="stylesheet" href="../../_static/css/theme.css" type="text/css" /> |
| 6 | + <title>stream2py.stream_buffer — stream2py 1.0.34 documentation</title><link rel="stylesheet" href="../../_static/css/theme.css" type="text/css" /> |
7 | 7 | <link rel="stylesheet" href="../../_static/pygments.css" type="text/css" />
|
8 | 8 | <link rel="stylesheet" href="../../_static/copybutton.css" type="text/css" />
|
9 | 9 | <link rel="stylesheet" href="../../_static/graphviz.css" type="text/css" />
|
@@ -335,14 +335,34 @@ <h1>Source code for stream2py.stream_buffer</h1><div class="highlight"><pre>
|
335 | 335 |
|
336 | 336 | <span class="k">def</span> <span class="nf">_open</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
337 | 337 | <span class="sd">"""First thing called after start/run</span>
|
338 |
| -<span class="sd"> Calls source_reader.open() and then sets up source_buffer with latest source_reader.info"""</span> |
| 338 | +<span class="sd"> Calls source_reader.open() and then sets up source_buffer with latest</span> |
| 339 | +<span class="sd"> source_reader.info"""</span> |
339 | 340 | <span class="bp">self</span><span class="o">.</span><span class="n">source_reader</span><span class="o">.</span><span class="n">open</span><span class="p">()</span>
|
340 | 341 | <span class="bp">self</span><span class="o">.</span><span class="n">source_buffer</span> <span class="o">=</span> <span class="n">_SourceBuffer</span><span class="p">(</span>
|
341 | 342 | <span class="n">source_reader_info</span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">source_reader</span><span class="o">.</span><span class="n">info</span><span class="p">,</span>
|
342 | 343 | <span class="n">stop_event</span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">_stop_event</span><span class="p">,</span>
|
343 | 344 | <span class="n">key</span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">source_reader</span><span class="o">.</span><span class="n">key</span><span class="p">,</span>
|
344 | 345 | <span class="n">maxlen</span><span class="o">=</span><span class="bp">self</span><span class="o">.</span><span class="n">_maxlen</span><span class="p">,</span>
|
345 |
| - <span class="p">)</span></div> |
| 346 | + <span class="p">)</span> |
| 347 | + |
| 348 | + <span class="k">def</span> <span class="nf">_mk_contextualized_iterator</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span> |
| 349 | + <span class="sd">"""Return next item (entering the context beforehand, if not running).</span> |
| 350 | +<span class="sd"> This method is meant to be called under context so that a clean exit is assured.</span> |
| 351 | +<span class="sd"> """</span> |
| 352 | + <span class="k">if</span> <span class="ow">not</span> <span class="bp">self</span><span class="o">.</span><span class="n">is_running</span><span class="p">:</span> |
| 353 | + <span class="bp">self</span><span class="o">.</span><span class="fm">__enter__</span><span class="p">()</span> |
| 354 | + <span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="fm">__next__</span><span class="p">()</span> |
| 355 | + |
| 356 | + <span class="k">def</span> <span class="fm">__call__</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span> |
| 357 | + <span class="sd">"""Return next item (entering the context beforehand, if not running).</span> |
| 358 | +<span class="sd"> This method is meant to be called under context so that a clean exit is assured. """</span> |
| 359 | + <span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="n">_mk_contextualized_iterator</span><span class="p">()</span> |
| 360 | + |
| 361 | + <span class="k">def</span> <span class="fm">__del__</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span> |
| 362 | + <span class="k">try</span><span class="p">:</span> |
| 363 | + <span class="k">return</span> <span class="bp">self</span><span class="o">.</span><span class="fm">__exit__</span><span class="p">(</span><span class="kc">None</span><span class="p">,</span> <span class="kc">None</span><span class="p">,</span> <span class="kc">None</span><span class="p">)</span> |
| 364 | + <span class="k">except</span> <span class="ne">Exception</span><span class="p">:</span> |
| 365 | + <span class="k">pass</span></div> |
346 | 366 | </pre></div>
|
347 | 367 |
|
348 | 368 | </div>
|
|
0 commit comments