code: def _filter(self, stream_item):
      return (
          self.filter_expr(stream_item)
          if self.filter_expr is not None
          else (stream_item, True)
      )
  
imports: from .stream import Stream
  from typing import Callable, Any
label_desc: Use image node_id 2 for calling the FilteredStream obj's underlying member method code with example usage: obj._filter(stream_item) and returns: unknown