Show More
@@ -642,12 +642,12 b' class observedbufferedinputpipe(buffered' | |||||
642 | ``read()`` and ``readline()``. |
|
642 | ``read()`` and ``readline()``. | |
643 | """ |
|
643 | """ | |
644 |
|
644 | |||
645 | def _fillbuffer(self): |
|
645 | def _fillbuffer(self, size=_chunksize): | |
646 | res = super(observedbufferedinputpipe, self)._fillbuffer() |
|
646 | res = super(observedbufferedinputpipe, self)._fillbuffer(size=size) | |
647 |
|
647 | |||
648 | fn = getattr(self._input._observer, 'osread', None) |
|
648 | fn = getattr(self._input._observer, 'osread', None) | |
649 | if fn: |
|
649 | if fn: | |
650 |
fn(res, |
|
650 | fn(res, size) | |
651 |
|
651 | |||
652 | return res |
|
652 | return res | |
653 |
|
653 |
General Comments 0
You need to be logged in to leave comments.
Login now