grassrootseconomics/openethereum
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

RlpStream array method

Browse Source
This commit is contained in:
debris 2015-11-25 19:36:27 +01:00
parent 798b8b0fb8
commit 9f938fbaab
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/rlp.rs
View File

@ -191,7 +191,7 @@ impl <'a> Iterator for RlpIterator<'a> {
} }
} }
/// container that should be used to encoding the rlp /// container that should be used to encode rlp
pub struct RlpStream { pub struct RlpStream {
len: usize, len: usize,
max_len: usize, max_len: usize,
@ -200,8 +200,14 @@ pub struct RlpStream {
} }
impl RlpStream { impl RlpStream {
/// create new container of size `max_len` /// create new container for values appended one after another,
pub fn new(max_len: usize) -> RlpStream { /// but not being part of the same array
pub fn new() -> RlpStream {
RlpStream::array(0)
}
/// create new container for array of size `max_len`
pub fn array(max_len: usize) -> RlpStream {
RlpStream { RlpStream {
len: 0, len: 0,
max_len: max_len, max_len: max_len,
@ -238,7 +244,7 @@ impl RlpStream {
self self
} }
/// return try if stream is ready /// return true if stream is ready
pub fn is_finished(&self) -> bool { pub fn is_finished(&self) -> bool {
self.len == self.max_len self.len == self.max_len
} }
@ -593,7 +599,7 @@ mod tests {
#[test] #[test]
fn rlp_stream() { fn rlp_stream() {
let mut stream = RlpStream::new(2); let mut stream = RlpStream::array(2);
stream.append(&"cat").append(&"dog"); stream.append(&"cat").append(&"dog");
let out = stream.out().unwrap(); let out = stream.out().unwrap();
assert_eq!(out, vec![0xc8, 0x83, b'c', b'a', b't', 0x83, b'd', b'o', b'g']); assert_eq!(out, vec![0xc8, 0x83, b'c', b'a', b't', 0x83, b'd', b'o', b'g']);