Updates the is_writable attribute on all sockets currently in the Pool.
(self, is_writable: Optional[bool])
| 898 | await conn.close_conn(ConnectionClosedReason.STALE) |
| 899 | |
| 900 | async def update_is_writable(self, is_writable: Optional[bool]) -> None: |
| 901 | """Updates the is_writable attribute on all sockets currently in the |
| 902 | Pool. |
| 903 | """ |
| 904 | self.is_writable = is_writable |
| 905 | async with self.lock: |
| 906 | for _socket in self.conns: |
| 907 | _socket.update_is_writable(self.is_writable) # type: ignore[arg-type] |
| 908 | |
| 909 | async def reset( |
| 910 | self, service_id: Optional[ObjectId] = None, interrupt_connections: bool = False |
no outgoing calls
no test coverage detected