def get_streams(self):
        """
        Return a snapshot of all streams in existence at time of call.
        """
        self._write_lock.acquire()
        try:
            return itervalues(self._stream_by_id)
        finally:
            self._write_lock.release()
def get_streams ( self ) : self . _write_lock . acquire ( ) try : return itervalues ( self . _stream_by_id ) finally : self . _write_lock . release ( )
Return a snapshot of all streams in existence at time of call.