equal
deleted
inserted
replaced
96 |
96 |
97 loop { |
97 loop { |
98 buf.read_from(&mut stream)?; |
98 buf.read_from(&mut stream)?; |
99 |
99 |
100 while let Ok((tail, msg)) = parser::server_message(buf.as_ref()) { |
100 while let Ok((tail, msg)) = parser::server_message(buf.as_ref()) { |
101 buf.consume(buf.len() - tail.len()); |
101 let tail_len = tail.len(); |
|
102 buf.consume(buf.len() - tail_len); |
102 |
103 |
103 match msg { |
104 match msg { |
104 Connected(_, _) => { |
105 Connected(_, _) => { |
105 info!("Connected"); |
106 info!("Connected"); |
106 stream.write( |
107 stream.write( |
152 } |
153 } |
153 ChatMsg { nick, msg } => { |
154 ChatMsg { nick, msg } => { |
154 info!("Chat [{}]: {}", nick, msg); |
155 info!("Chat [{}]: {}", nick, msg); |
155 } |
156 } |
156 RoomAdd(fields) => { |
157 RoomAdd(fields) => { |
157 let mut l = fields.into_iter(); |
158 let l = fields.into_iter(); |
158 info!("Room added: {}", l.skip(1).next().unwrap()); |
159 info!("Room added: {}", l.skip(1).next().unwrap()); |
159 } |
160 } |
160 RoomUpdated(name, fields) => { |
161 RoomUpdated(name, fields) => { |
161 let mut l = fields.into_iter(); |
162 let l = fields.into_iter(); |
162 let new_name = l.skip(1).next().unwrap(); |
163 let new_name = l.skip(1).next().unwrap(); |
163 |
164 |
164 if (name != new_name) { |
165 if name != new_name { |
165 info!("Room renamed: {}", new_name); |
166 info!("Room renamed: {}", new_name); |
166 } |
167 } |
167 } |
168 } |
168 RoomRemove(_) => { |
169 RoomRemove(_) => { |
169 // ignore |
170 // ignore |