chore(release): 0.4.0 #12
@@ -103,14 +103,11 @@ class BackendServer:
|
||||
|
||||
client.disconnect()
|
||||
|
||||
def _send_outbound(
|
||||
self, sock: socket.socket, client: Client, data: bytes
|
||||
) -> None:
|
||||
def _send_outbound(self, sock: socket.socket, client: Client) -> None:
|
||||
"""Queue data to be sent to a client.
|
||||
|
||||
Args:
|
||||
client (Client): The client to send data to.
|
||||
data (bytes): The data to send.
|
||||
"""
|
||||
self.logger.debug(f"[>] Sending data to {client}: {client.outbound!r}")
|
||||
sent = sock.send(client.outbound)
|
||||
@@ -219,7 +216,7 @@ class BackendServer:
|
||||
|
||||
if mask & selectors.EVENT_WRITE:
|
||||
if client.outbound:
|
||||
self._send_outbound(sock, client, client.outbound)
|
||||
self._send_outbound(sock, client)
|
||||
|
||||
except ConnectionResetError as e:
|
||||
self.logger.error(f"Connection reset by {client}, disconnect: {e}")
|
||||
|
||||
Reference in New Issue
Block a user