diff options
| author | Victor Stinner <victor.stinner@gmail.com> | 2014-12-11 21:23:19 (GMT) |
|---|---|---|
| committer | Victor Stinner <victor.stinner@gmail.com> | 2014-12-11 21:23:19 (GMT) |
| commit | df75d5b402fa7d9377dd6e38f3ad7551de6746d5 (patch) | |
| tree | 3b426cf7c554c18d0eb36d88b8085f961854d2b3 /Lib/asyncio/proactor_events.py | |
| parent | 049882e561aeae334e71063792ddd7883fc52764 (diff) | |
| download | cpython-df75d5b402fa7d9377dd6e38f3ad7551de6746d5.zip cpython-df75d5b402fa7d9377dd6e38f3ad7551de6746d5.tar.gz cpython-df75d5b402fa7d9377dd6e38f3ad7551de6746d5.tar.bz2 | |
asyncio, tulip issue 202: Add unit test of pause/resume writing for proactor
socket transport
Diffstat (limited to 'Lib/asyncio/proactor_events.py')
| -rw-r--r-- | Lib/asyncio/proactor_events.py | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/Lib/asyncio/proactor_events.py b/Lib/asyncio/proactor_events.py index 4c527aa..e67cf65 100644 --- a/Lib/asyncio/proactor_events.py +++ b/Lib/asyncio/proactor_events.py @@ -230,10 +230,6 @@ class _ProactorBaseWritePipeTransport(_ProactorBasePipeTransport, assert self._buffer is None # Pass a copy, except if it's already immutable. self._loop_writing(data=bytes(data)) - # XXX Should we pause the protocol at this point - # if len(data) > self._high_water? (That would - # require keeping track of the number of bytes passed - # to a send() that hasn't finished yet.) elif not self._buffer: # WRITING -> BACKED UP # Make a mutable copy which we can extend. self._buffer = bytearray(data) |