code: def _write(self, *args, **kwargs):
          
          if self.filter_fn(*args, **kwargs):
              self.stream.write(*args, **kwargs)
docs: Writes to the consumer stream when *filter_fn* evaluates to *True*, passing *args* and
          *kwargs*.