Have .stream() return the ExtendedTask; Add a .clear() method

Author: cpsievert

shiny/ui/_markdown_stream.py

@@ -168,6 +168,14 @@ async def _handle_error():
                 await self._raise_exception(e)
             _handle_error.destroy()  # type: ignore
 
+        return _task
+
+    async def clear(self):
+        """
+        Clear the content of the markdown stream.
+        """
+        return await self.stream([], clear=True)
+
     @asynccontextmanager
     async def _streaming_dot(self):
         await self._send_stream_message(True)