We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
# pylint: disable
1 parent f92e1ef commit 4fa2b9cCopy full SHA for 4fa2b9c
src/frequenz/channels/_receiver.py
@@ -373,9 +373,7 @@ def consume(self) -> MappedMessageT_co: # noqa: DOC502
373
ReceiverStoppedError: If the receiver stopped producing messages.
374
ReceiverError: If there is a problem with the receiver.
375
"""
376
- return self._mapping_function(
377
- self._receiver.consume()
378
- ) # pylint: disable=protected-access
+ return self._mapping_function(self._receiver.consume())
379
380
def __str__(self) -> str:
381
"""Return a string representation of the mapper."""
0 commit comments