code: def __init__(
      self,
      source_stream: Stream,
      filter_expr: Callable,
      stream_name: str = None,
      console_debug: bool = False,
  ) -> None:
      stream_name = stream_name or "{}|{}".format(
          source_stream.stream_name, str(filter_expr)
      )
      super(FilteredStream, self).__init__(
          stream_name=stream_name, console_debug=console_debug
      )
      self.subscribe(source_stream)
      self.filter_expr = filter_expr
  
imports: from .stream import Stream
  from typing import Callable, Any
label_desc: Use image node_id 1 to create a new FilteredStream object from inherited base classes: Stream with example: obj = FilteredStream(source_stream, filter_expr, stream_name, console_debug)