| 250 | This is much like a bound, listening socket. |
| 251 | """ |
| 252 | def __init__(self, address): |
| 253 | self._address = address |
| 254 | self._free_instances = weakref.WeakSet() |
| 255 | # initialize the pipe attribute before calling _server_pipe_handle() |
| 256 | # because this function can raise an exception and the destructor calls |
| 257 | # the close() method |
| 258 | self._pipe = None |
| 259 | self._accept_pipe_future = None |
| 260 | self._pipe = self._server_pipe_handle(True) |
| 261 | |
| 262 | def _get_unconnected_pipe(self): |
| 263 | # Create new instance and return previous one. This ensures |