Skip to content

Commit a8982b3

Browse files
committed
Remove obsolete param 'streaming' in BaseIOStream._finish_read()
Parameter 'streaming' has been obsolete since a55c7fe in 2018-07 when `_run_read_callback()` was renamed to `_finish_read()`. This param should be removed as well after the removal of callback in IOStream.
1 parent 208672f commit a8982b3

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

tornado/iostream.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -497,7 +497,7 @@ def read_until_close(self) -> Awaitable[bytes]:
497497
"""
498498
future = self._start_read()
499499
if self.closed():
500-
self._finish_read(self._read_buffer_size, False)
500+
self._finish_read(self._read_buffer_size)
501501
return future
502502
self._read_until_close = True
503503
try:
@@ -595,7 +595,7 @@ def close(
595595
self.error = exc_info[1]
596596
if self._read_until_close:
597597
self._read_until_close = False
598-
self._finish_read(self._read_buffer_size, False)
598+
self._finish_read(self._read_buffer_size)
599599
elif self._read_future is not None:
600600
# resolve reads that are pending and ready to complete
601601
try:
@@ -812,7 +812,7 @@ def _start_read(self) -> Future:
812812
self._read_future = Future()
813813
return self._read_future
814814

815-
def _finish_read(self, size: int, streaming: bool) -> None:
815+
def _finish_read(self, size: int) -> None:
816816
if self._user_read_buffer:
817817
self._read_buffer = self._after_user_read_buffer or bytearray()
818818
self._after_user_read_buffer = None
@@ -904,7 +904,7 @@ def _read_from_buffer(self, pos: int) -> None:
904904
"""
905905
self._read_bytes = self._read_delimiter = self._read_regex = None
906906
self._read_partial = False
907-
self._finish_read(pos, False)
907+
self._finish_read(pos)
908908

909909
def _find_read_pos(self) -> Optional[int]:
910910
"""Attempts to find a position in the read buffer that satisfies

0 commit comments

Comments
 (0)