</span> <span class="ne">Exception</span><span class="p">(</span><span class="sa">f</span><span class="s1">'Stream with name: </span><span class="si">{</span><span class="n">name</span><span class="si">}</span><span class="s1"> not found'</span><span class="p">)</span>

            <span class="n">stream</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">_streams</span><span class="p">[</span><span class="n">name</span><span class="p">]</span>

        <span 