Connect to the named pipe ``addr`` :returns type: :class:`PipeConnection`
(cls, addr)
| 65 | |
| 66 | @classmethod |
| 67 | def connect(cls, addr): |
| 68 | """Connect to the named pipe ``addr`` |
| 69 | |
| 70 | :returns type: :class:`PipeConnection` |
| 71 | """ |
| 72 | addr = full_pipe_address(addr) |
| 73 | pipehandle = winproxy.CreateFileA(addr, gdef.GENERIC_READ | gdef.GENERIC_WRITE, 0, None, gdef.OPEN_EXISTING, 0, None) |
| 74 | winproxy.SetNamedPipeHandleState(pipehandle, gdef.ULONG(gdef.PIPE_READMODE_MESSAGE), None, None) |
| 75 | return cls.from_handle(pipehandle, name=addr, server=False) |
| 76 | |
| 77 | def send(self, *args, **kwargs): |
| 78 | """Send an object on the pipe""" |
nothing calls this directly
no test coverage detected