Skip to content

Commit 847f955

Browse files
committed
fix pylint errors
1 parent 5e41abc commit 847f955

1 file changed

Lines changed: 3 additions & 9 deletions

File tree

splitgpg2/__init__.py

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1409,11 +1409,8 @@ class FlowControlMixin(asyncio.protocols.Protocol):
14091409
StreamWriter.drain() must wait for _drain_helper() coroutine.
14101410
"""
14111411

1412-
def __init__(self, loop=None):
1413-
if loop is None:
1414-
self._loop = events.get_event_loop()
1415-
else:
1416-
self._loop = loop
1412+
def __init__(self, loop):
1413+
self._loop = loop
14171414
self._paused = False
14181415
self._drain_waiters = collections.deque()
14191416
self._connection_lost = False
@@ -1422,14 +1419,10 @@ def __init__(self, loop=None):
14221419
def pause_writing(self):
14231420
assert not self._paused
14241421
self._paused = True
1425-
if self._loop.get_debug():
1426-
logger.debug("%r pauses writing", self)
14271422

14281423
def resume_writing(self):
14291424
assert self._paused
14301425
self._paused = False
1431-
if self._loop.get_debug():
1432-
logger.debug("%r resumes writing", self)
14331426

14341427
for waiter in self._drain_waiters:
14351428
if not waiter.done():
@@ -1465,6 +1458,7 @@ async def _drain_helper(self):
14651458
finally:
14661459
self._drain_waiters.remove(waiter)
14671460

1461+
# pylint: disable=unused-argument
14681462
def _get_close_waiter(self, stream):
14691463
return self._closed
14701464

0 commit comments

Comments
 (0)