Fix communication over unix socket
This commit is contained in:
parent
1a813083e5
commit
02838658b0
@ -130,9 +130,15 @@ class UnixSocket:
|
|||||||
super().connect(self._socket_path)
|
super().connect(self._socket_path)
|
||||||
|
|
||||||
|
|
||||||
|
class SocketClient(_Socket, socket.socket):
|
||||||
|
|
||||||
|
def read(self):
|
||||||
|
return self.recv()
|
||||||
|
|
||||||
|
|
||||||
class _Listener:
|
class _Listener:
|
||||||
|
|
||||||
def __init__(self, new_server_cb, instanciate=_Socket, **kwargs):
|
def __init__(self, new_server_cb, instanciate=SocketClient, **kwargs):
|
||||||
super().__init__(**kwargs)
|
super().__init__(**kwargs)
|
||||||
|
|
||||||
self._instanciate = instanciate
|
self._instanciate = instanciate
|
||||||
|
Loading…
x
Reference in New Issue
Block a user