Method
__init__
(
self,
socket: socket.socket,
protocol: ClientProtocol,
*,
ping_interval: float | None = 20,
ping_timeout: float | None = 20,
close_timeout: float | None = 10,
max_queue: int | None | tuple[int | None, int | None] = 16,
)
Source from the content-addressed store, hash-verified
| 53 | """ |
| 54 | |
| 55 | def __init__( |
| 56 | self, |
| 57 | socket: socket.socket, |
| 58 | protocol: ClientProtocol, |
| 59 | *, |
| 60 | ping_interval: float | None = 20, |
| 61 | ping_timeout: float | None = 20, |
| 62 | close_timeout: float | None = 10, |
| 63 | max_queue: int | None | tuple[int | None, int | None] = 16, |
| 64 | ) -> None: |
| 65 | self.protocol: ClientProtocol |
| 66 | self.response_rcvd = threading.Event() |
| 67 | super().__init__( |
| 68 | socket, |
| 69 | protocol, |
| 70 | ping_interval=ping_interval, |
| 71 | ping_timeout=ping_timeout, |
| 72 | close_timeout=close_timeout, |
| 73 | max_queue=max_queue, |
| 74 | ) |
| 75 | |
| 76 | def handshake( |
| 77 | self, |
Callers
nothing calls this directly
Tested by
no test coverage detected