def METHOD_NAME(self, source: str, **kwargs: t.Any) -> str:  # type: ignore
    source = f"{source.rstrip()}\n"
    ThreadedStream.push()
    prompt = "... " if self.more else ">>> "
    try:
        source_to_eval = "".join(self.buffer + [source])
        if super().METHOD_NAME(source_to_eval, "<debugger>", "single"):
            self.more = True
            self.buffer.append(source)
        else:
            self.more = False
            del self.buffer[:]
    finally:
        output = ThreadedStream.fetch()
    return f"{prompt}{escape(source)}{output}"