Method
__init__
(
self,
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,
write_limit: int | tuple[int, int | None] = 2**15,
)
Source from the content-addressed store, hash-verified
| 65 | """ |
| 66 | |
| 67 | def __init__( |
| 68 | self, |
| 69 | protocol: ClientProtocol, |
| 70 | *, |
| 71 | ping_interval: float | None = 20, |
| 72 | ping_timeout: float | None = 20, |
| 73 | close_timeout: float | None = 10, |
| 74 | max_queue: int | None | tuple[int | None, int | None] = 16, |
| 75 | write_limit: int | tuple[int, int | None] = 2**15, |
| 76 | ) -> None: |
| 77 | self.protocol: ClientProtocol |
| 78 | super().__init__( |
| 79 | protocol, |
| 80 | ping_interval=ping_interval, |
| 81 | ping_timeout=ping_timeout, |
| 82 | close_timeout=close_timeout, |
| 83 | max_queue=max_queue, |
| 84 | write_limit=write_limit, |
| 85 | ) |
| 86 | self.response_rcvd: asyncio.Future[None] = self.loop.create_future() |
| 87 | |
| 88 | async def handshake( |
| 89 | self, |
Callers
nothing calls this directly
Tested by
no test coverage detected