diff --git a/fstream-server.py b/fstream-server.py
index 1bb1177..65662a3 100644
--- a/fstream-server.py
+++ b/fstream-server.py
@@ -90,6 +90,12 @@ def commandToList(cmd):
 
 def closeConnection(connectionId):
 	if connectionId in connections:
+		try:
+			connections[connectionId]["connection"].close()
+		except Exception as e:
+			print("Failed to close connection: " +str(e))
+			pass
+		
 		del connections[connectionId]
 
 class outThread(threading.Thread):