class="ow">in</span> <span class="n">closed_streams</span><span class="p">:</span>
                <span class="k">del</span> <span class="bp">self</span><span class="o">.</span><span class="n">_streams</span><span class="p">[</span><span class="n">stream</span><span class="p">]</span></div>



    <span class="k">def</span><span class="w"> </span><span class="nf">_processing_thread_loop</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
<span class="w">        </span><span 