81 self.send = function (_, data) return w(conn, t(data)); end |
81 self.send = function (_, data) return w(conn, t(data)); end |
82 return true; |
82 return true; |
83 end |
83 end |
84 |
84 |
85 function stream:close() |
85 function stream:close() |
|
86 if not self.conn then |
|
87 verse.log("error", "Attempt to close disconnected connection - possibly a bug"); |
|
88 return; |
|
89 end |
86 local on_disconnect = self.conn.disconnect(); |
90 local on_disconnect = self.conn.disconnect(); |
87 self.conn:close(); |
91 self.conn:close(); |
88 on_disconnect(conn, reason); |
92 on_disconnect(conn, reason); |
89 end |
93 end |
90 |
94 |