From 02015e44cd42d8b42a72012770208a41c54ac17d Mon Sep 17 00:00:00 2001 From: Yury Selivanov Date: Thu, 6 Feb 2014 00:11:28 -0500 Subject: streams.StreamReader: Add 'at_eof()' method --- asyncio/streams.py | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'asyncio/streams.py') diff --git a/asyncio/streams.py b/asyncio/streams.py index 3da1d10..8fc2147 100644 --- a/asyncio/streams.py +++ b/asyncio/streams.py @@ -293,6 +293,10 @@ class StreamReader: if not waiter.cancelled(): waiter.set_result(True) + def at_eof(self): + """Return True if the buffer is empty and 'feed_eof' was called.""" + return self._eof and not self._buffer + def feed_data(self, data): assert not self._eof, 'feed_data after feed_eof' -- cgit v1.2.1