def METHOD_NAME(
    self, stream_name: str, original_stream: TextIO, data: str
) -> None:
    if self._tee_output:
        original_stream.write(data)
        original_stream.flush()
    self._events.send(Log(data, source=stream_name))