diff options
| author | Yury Selivanov <yselivanov@sprymix.com> | 2014-02-19 16:10:52 (GMT) |
|---|---|---|
| committer | Yury Selivanov <yselivanov@sprymix.com> | 2014-02-19 16:10:52 (GMT) |
| commit | 2d01c0a08033fb1f10a648135372d857d3f5d6ca (patch) | |
| tree | dedb4b37f9c938c8a1984a76786b2e83adb61241 /Lib/asyncio/transports.py | |
| parent | 03e9cb2b0b82741c578cbc14ddcd8564d6e7a9e7 (diff) | |
| download | cpython-2d01c0a08033fb1f10a648135372d857d3f5d6ca.zip cpython-2d01c0a08033fb1f10a648135372d857d3f5d6ca.tar.gz cpython-2d01c0a08033fb1f10a648135372d857d3f5d6ca.tar.bz2 | |
asyncio: WriteTransport.set_write_buffer_size to call _maybe_pause_protocol
Diffstat (limited to 'Lib/asyncio/transports.py')
| -rw-r--r-- | Lib/asyncio/transports.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/Lib/asyncio/transports.py b/Lib/asyncio/transports.py index 5b975aa..5f674f9 100644 --- a/Lib/asyncio/transports.py +++ b/Lib/asyncio/transports.py @@ -241,7 +241,7 @@ class _FlowControlMixin(Transport): def __init__(self, extra=None): super().__init__(extra) self._protocol_paused = False - self.set_write_buffer_limits() + self._set_write_buffer_limits() def _maybe_pause_protocol(self): size = self.get_write_buffer_size() @@ -273,7 +273,7 @@ class _FlowControlMixin(Transport): 'protocol': self._protocol, }) - def set_write_buffer_limits(self, high=None, low=None): + def _set_write_buffer_limits(self, high=None, low=None): if high is None: if low is None: high = 64*1024 @@ -287,5 +287,9 @@ class _FlowControlMixin(Transport): self._high_water = high self._low_water = low + def set_write_buffer_limits(self, high=None, low=None): + self._set_write_buffer_limits(high=high, low=low) + self._maybe_pause_protocol() + def get_write_buffer_size(self): raise NotImplementedError |