Skip to content
Snippets Groups Projects
Commit 44d6ba08 authored by phil's avatar phil
Browse files

Fix TCP*Pipe stop() method

parent 888f753e
No related branches found
No related tags found
No related merge requests found
......@@ -161,7 +161,8 @@ class TCPConnectPipe(Source):
self.fd = socket.socket()
self.fd.connect((self.addr,self.port))
def stop(self):
self.fd.close()
if self.fd:
self.fd.close()
def push(self, msg):
self.fd.send(msg)
def fileno(self):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment