Track master: proc removal, tuple indexing
This commit is contained in:
parent
9754b8e47d
commit
6119d916cb
|
|
@ -541,7 +541,7 @@ impl<S: Stream> Writer for SslStream<S> {
|
||||||
let mut start = 0;
|
let mut start = 0;
|
||||||
while start < buf.len() {
|
while start < buf.len() {
|
||||||
let ret = self.in_retry_wrapper(|ssl| {
|
let ret = self.in_retry_wrapper(|ssl| {
|
||||||
ssl.write(buf.split_at(start).val1())
|
ssl.write(buf.split_at(start).1)
|
||||||
});
|
});
|
||||||
match ret {
|
match ret {
|
||||||
Ok(len) => start += len as uint,
|
Ok(len) => start += len as uint,
|
||||||
|
|
|
||||||
|
|
@ -198,7 +198,7 @@ fn test_clone() {
|
||||||
let stream = TcpStream::connect("127.0.0.1:15418").unwrap();
|
let stream = TcpStream::connect("127.0.0.1:15418").unwrap();
|
||||||
let mut stream = SslStream::new(&SslContext::new(Sslv23).unwrap(), stream).unwrap();
|
let mut stream = SslStream::new(&SslContext::new(Sslv23).unwrap(), stream).unwrap();
|
||||||
let mut stream2 = stream.clone();
|
let mut stream2 = stream.clone();
|
||||||
spawn(proc() {
|
spawn(move || {
|
||||||
stream2.write("GET /\r\n\r\n".as_bytes()).unwrap();
|
stream2.write("GET /\r\n\r\n".as_bytes()).unwrap();
|
||||||
stream2.flush().unwrap();
|
stream2.flush().unwrap();
|
||||||
});
|
});
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue