@@ -34,10 +34,10 @@ impl Encoder for Codec {
34
34
write_rn ( buf) ;
35
35
}
36
36
Request :: BulkInteger ( i) => {
37
- let mut len_buf = [ 0 ; 32 ] ;
38
- let size = itoa :: write ( & mut len_buf [ .. ] , i ) . unwrap ( ) ;
39
- write_header ( b'$' , size as i64 , buf, size + 2 ) ;
40
- buf. extend_from_slice ( & len_buf [ ..size ] ) ;
37
+ let mut buffer = itoa :: Buffer :: new ( ) ;
38
+ let rendered = buffer . format ( i ) ;
39
+ write_header ( b'$' , rendered . len ( ) as i64 , buf, rendered . len ( ) + 2 ) ;
40
+ buf. extend_from_slice ( rendered . as_bytes ( ) ) ;
41
41
write_rn ( buf) ;
42
42
}
43
43
Request :: String ( ref string) => {
@@ -533,11 +533,11 @@ fn write_rn(buf: &mut BytesMut) {
533
533
}
534
534
535
535
fn write_header ( symb : u8 , len : i64 , buf : & mut BytesMut , body_size : usize ) {
536
- let mut len_buf = [ 0 ; 32 ] ;
537
- let size = itoa :: write ( & mut len_buf[ .. ] , len ) . unwrap ( ) ;
538
- buf. reserve ( 3 + size + body_size) ;
536
+ let mut len_buf = itoa :: Buffer :: new ( ) ;
537
+ let rendered = len_buf. format ( len ) ;
538
+ buf. reserve ( 3 + rendered . len ( ) + body_size) ;
539
539
buf. put_u8 ( symb) ;
540
- buf. extend_from_slice ( & len_buf [ ..size ] ) ;
540
+ buf. extend_from_slice ( rendered . as_bytes ( ) ) ;
541
541
write_rn ( buf) ;
542
542
}
543
543
0 commit comments