Changed outgoing future to panic on error (since the code currently does

that anyway).
This commit is contained in:
Aaron Weiss 2017-06-27 14:26:04 -07:00
parent c6028b2e0e
commit 8fa6f85001
No known key found for this signature in database
GPG key ID: 0237035D9BF03AE2

View file

@ -552,7 +552,7 @@ impl IrcServer {
let outgoing_future = sink.send_all(rx_outgoing.map_err(|_| {
let res: error::Error = error::ErrorKind::ChannelError.into();
res
})).map(|_| ()).map_err(|_| ());
})).map(|_| ()).map_err(|e| panic!("{}", e));
// Send the stream half back to the original thread.
tx_incoming.send(stream).unwrap();