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