equal
deleted
inserted
replaced
17 |
17 |
18 pub fn send_message(&mut self, message: &EngineMessage) { |
18 pub fn send_message(&mut self, message: &EngineMessage) { |
19 self.out_buffer.write(&message.to_bytes()).unwrap(); |
19 self.out_buffer.write(&message.to_bytes()).unwrap(); |
20 } |
20 } |
21 |
21 |
22 pub fn iter(& mut self) -> IPCMessagesIterator { |
22 pub fn iter(&mut self) -> IPCMessagesIterator { |
23 IPCMessagesIterator::new(self) |
23 IPCMessagesIterator::new(self) |
24 } |
24 } |
25 } |
25 } |
26 |
26 |
27 impl Write for IPC { |
27 impl Write for IPC { |
43 Ok(read_bytes) |
43 Ok(read_bytes) |
44 } |
44 } |
45 } |
45 } |
46 |
46 |
47 pub struct IPCMessagesIterator<'a> { |
47 pub struct IPCMessagesIterator<'a> { |
48 ipc: &'a mut IPC |
48 ipc: &'a mut IPC, |
49 } |
49 } |
50 |
50 |
51 impl<'a> IPCMessagesIterator<'a> { |
51 impl<'a> IPCMessagesIterator<'a> { |
52 pub fn new(ipc: &'a mut IPC) -> Self { |
52 pub fn new(ipc: &'a mut IPC) -> Self { |
53 Self { |
53 Self { ipc } |
54 ipc |
|
55 } |
|
56 } |
54 } |
57 } |
55 } |
58 |
56 |
59 impl<'a> Iterator for IPCMessagesIterator<'a> { |
57 impl<'a> Iterator for IPCMessagesIterator<'a> { |
60 type Item = EngineMessage; |
58 type Item = EngineMessage; |