mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

refactor: update _feed_buffer param info 

Co-authored-by: Andrew Mirsky <andrew@mirsky.net>
pull/165/head
MVladislav 2025-05-17 18:00:43 +02:00 zatwierdzone przez GitHub
rodzic 5bee2a9af9
commit 36697261ca
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: B5690EEEBB952194
1 zmienionych plików z 1 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

2
amqtt/adapters.py
Wyświetl plik

@ -75,7 +75,7 @@ class WebSocketsReader(ReaderAdapter):
async def _feed_buffer(self, n: int = 1) -> None: async def _feed_buffer(self, n: int = 1) -> None:
"""Feed the data buffer by reading a WebSocket message. """Feed the data buffer by reading a WebSocket message.
:param n: if given, feed buffer until it contains at least n bytes. :param n: Optional; feed buffer until it contains at least n bytes. Defaults to 1.
""" """
buffer = bytearray(self._stream.read()) buffer = bytearray(self._stream.read())
message: str | bytes | None = None message: str | bytes | None = None