diff -r d67ad403ca55 -r f0aec10023aa init.lua
--- a/init.lua	Sat Aug 21 14:35:51 2010 +0100
+++ b/init.lua	Sat Aug 21 14:36:21 2010 +0100
@@ -63,6 +63,13 @@
 	self.conn = conn;
 	local w, t = conn.write, tostring;
 	self.send = function (_, data) return w(conn, t(data)); end
+	return true;
+end
+
+function stream:close()
+	local on_disconnect = self.conn.disconnect();
+	self.conn:close();
+	on_disconnect(conn, reason);
 end
 
 -- Logging functions