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