code: def _reset(self):
      # for each event, store (stream_name, stream_info)
      self._stream_infos: Dict[
          str, Dict[str, WatcherBase.StreamInfo]
      ] = {}
  
      self._global_vars: Dict[str, Any] = {}
      self._stream_count = 0
  
      # factory streams are shared per watcher instance
      self._stream_factory = StreamFactory()
  
      self.closed = False
  
imports: from typing import Dict, Any, Sequence
  from .lv_types import EventData, StreamItem, StreamCreateRequest, VisArgs
  from .evaler import Evaler
  from .stream import Stream
  from .stream_factory import StreamFactory
  from .filtered_stream import FilteredStream
  import uuid, time, functools
  from .None import utils
  from .notebook_maker import NotebookMaker
label_desc: Use image node_id 2 for calling the WatcherBase obj's underlying member method code with example usage: obj._reset() without return types