(self, address, callback)
| 76 | self.__socket.bind(addr) |
| 77 | |
| 78 | def asyncConnect(self, address, callback): |
| 79 | if (self.__acceptCallback): |
| 80 | raise AsyncException('Accept already in progress') |
| 81 | if (self.__connectCallback): |
| 82 | raise AsyncException('Connect already in progress') |
| 83 | if (self.__readCallback): |
| 84 | raise AsyncException('Read already in progress') |
| 85 | if (self.__writeAllCallback): |
| 86 | raise AsyncException('Write all already in progress') |
| 87 | if (self.__closed): |
| 88 | raise AsyncException('AsyncSocket closed') |
| 89 | |
| 90 | err = self.__socket.connect_ex(address) |
| 91 | if err in (errno.EINPROGRESS, errno.EWOULDBLOCK): |
| 92 | self.__connectCallback = callback |
| 93 | self.__asyncIOService.registerAsyncSocketForWrite(self) |
| 94 | else: |
| 95 | self.__asyncIOService.invokeLater( |
| 96 | functools.partial(callback, err = err)) |
| 97 | |
| 98 | def asyncAccept(self, callback): |
| 99 | if (self.__acceptCallback): |
no test coverage detected