diff --git a/nextline/main.py b/nextline/main.py index 4e33c639..f01b72f5 100644 --- a/nextline/main.py +++ b/nextline/main.py @@ -219,5 +219,5 @@ def flush(self): self._buffer = "" async def subscribe(self): - async for y in self._queue.subscribe(): # type: ignore + async for y in self._queue.subscribe(last=False): # type: ignore yield y