code: def read_all(
      self, from_stream: "Stream" = None
  ):  # override->replacement
      for subscribed_to in self._subscribed_to:
          for stream_item in subscribed_to.read_all(from_stream=self):
              result, is_valid = self._filter(stream_item)
              if is_valid:
                  yield stream_item
  
imports: from .stream import Stream
  from typing import Callable, Any
label_desc: Use image node_id 4 for calling the FilteredStream obj's underlying member method code with example usage: obj.read_all(from_stream) without return types