227 function conn_listener.onincoming(conn, data) |
227 function conn_listener.onincoming(conn, data) |
228 stream:event("incoming-raw", data); |
228 stream:event("incoming-raw", data); |
229 end |
229 end |
230 |
230 |
231 function conn_listener.ondisconnect(conn, err) |
231 function conn_listener.ondisconnect(conn, err) |
|
232 if conn.conn ~= stream.conn then return end |
232 stream.connected = false; |
233 stream.connected = false; |
233 stream:event("disconnected", { reason = err }); |
234 stream:event("disconnected", { reason = err }); |
234 end |
235 end |
235 |
236 |
236 function conn_listener.ondrain(conn) |
237 function conn_listener.ondrain(conn) |