@@ -169,7 +169,7 @@ mod tests {
169169 use net:: test:: { next_test_ip4, next_test_ip6} ;
170170 use sync:: mpsc:: channel;
171171 use sys_common:: AsInner ;
172- use time:: Duration ;
172+ use time:: { Instant , Duration } ;
173173 use thread;
174174
175175 fn each_ip ( f : & mut FnMut ( SocketAddr , SocketAddr ) ) {
@@ -370,22 +370,22 @@ mod tests {
370370 fn test_read_timeout ( ) {
371371 let addr = next_test_ip4 ( ) ;
372372
373- let mut stream = t ! ( UdpSocket :: bind( & addr) ) ;
373+ let stream = t ! ( UdpSocket :: bind( & addr) ) ;
374374 t ! ( stream. set_read_timeout( Some ( Duration :: from_millis( 1000 ) ) ) ) ;
375375
376376 let mut buf = [ 0 ; 10 ] ;
377- let wait = Duration :: span ( || {
378- let kind = stream . recv_from ( & mut buf ) . err ( ) . expect ( "expected error" ) . kind ( ) ;
379- assert ! ( kind == ErrorKind :: WouldBlock || kind == ErrorKind :: TimedOut ) ;
380- } ) ;
381- assert ! ( wait > Duration :: from_millis( 400 ) ) ;
377+
378+ let start = Instant :: now ( ) ;
379+ let kind = stream . recv_from ( & mut buf ) . err ( ) . expect ( "expected error" ) . kind ( ) ;
380+ assert ! ( kind == ErrorKind :: WouldBlock || kind == ErrorKind :: TimedOut ) ;
381+ assert ! ( start . elapsed ( ) > Duration :: from_millis( 400 ) ) ;
382382 }
383383
384384 #[ test]
385385 fn test_read_with_timeout ( ) {
386386 let addr = next_test_ip4 ( ) ;
387387
388- let mut stream = t ! ( UdpSocket :: bind( & addr) ) ;
388+ let stream = t ! ( UdpSocket :: bind( & addr) ) ;
389389 t ! ( stream. set_read_timeout( Some ( Duration :: from_millis( 1000 ) ) ) ) ;
390390
391391 t ! ( stream. send_to( b"hello world" , & addr) ) ;
@@ -394,10 +394,9 @@ mod tests {
394394 t ! ( stream. recv_from( & mut buf) ) ;
395395 assert_eq ! ( b"hello world" , & buf[ ..] ) ;
396396
397- let wait = Duration :: span ( || {
398- let kind = stream. recv_from ( & mut buf) . err ( ) . expect ( "expected error" ) . kind ( ) ;
399- assert ! ( kind == ErrorKind :: WouldBlock || kind == ErrorKind :: TimedOut ) ;
400- } ) ;
401- assert ! ( wait > Duration :: from_millis( 400 ) ) ;
397+ let start = Instant :: now ( ) ;
398+ let kind = stream. recv_from ( & mut buf) . err ( ) . expect ( "expected error" ) . kind ( ) ;
399+ assert ! ( kind == ErrorKind :: WouldBlock || kind == ErrorKind :: TimedOut ) ;
400+ assert ! ( start. elapsed( ) > Duration :: from_millis( 400 ) ) ;
402401 }
403402}
0 commit comments