equal
deleted
inserted
replaced
30 } |
30 } |
31 } |
31 } |
32 |
32 |
33 impl Read for IPC { |
33 impl Read for IPC { |
34 fn read(&mut self, buf: &mut [u8]) -> Result<usize> { |
34 fn read(&mut self, buf: &mut [u8]) -> Result<usize> { |
35 let result = self.out_buffer.as_ref().read(buf); |
35 let read_bytes = self.out_buffer.as_ref().read(buf)?; |
36 |
36 |
37 if let Ok(read_bytes) = result { |
37 self.out_buffer.consume(read_bytes); |
38 self.out_buffer.consume(read_bytes); |
|
39 } |
|
40 |
38 |
41 result |
39 Ok(read_bytes) |
42 } |
40 } |
43 } |
41 } |
44 |
42 |
45 impl Iterator for IPC { |
43 impl Iterator for IPC { |
46 type Item = EngineMessage; |
44 type Item = EngineMessage; |