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

Getting peer address with self._protocol.remote_address in WebSocketsWriter.get_peer_info

pull/8/head
Anton Lindroth 2019-11-28 07:30:27 +01:00
rodzic fc462d12bb
commit b0505ff093
1 zmienionych plików z 1 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

3
hbmqtt/adapters.py
Wyświetl plik

@ -121,8 +121,7 @@ class WebSocketsWriter(WriterAdapter):
self._stream = io.BytesIO(b'') self._stream = io.BytesIO(b'')
def get_peer_info(self): def get_peer_info(self):
extra_info = self._protocol.writer.get_extra_info('peername') return self._protocol.remote_address
return extra_info[0], extra_info[1]
@asyncio.coroutine @asyncio.coroutine
def close(self): def close(self):