Untitled

 avatar
unknown
rust
a year ago
906 B
7
Indexable
            'outer: loop {
                let cb_read = port.read(&mut buffer)?;
                if cb_read == 0 {
                    return Err(SendError::BrokenPipe);
                }

                let mut iter = self.parser.consume(&buffer[..cb_read]);
                'inner: loop {
                    let Some(raw_packet) = iter.next() else {
                        break 'inner;
                    };

                    let is_processed = match raw_packet {
                        Ok(packet) => {
                            handler(packet)?
                        }
                        Err(cause) => {
                            warn!("Malformed packet: {}", cause);
                            false
                        }
                    };

                    if is_processed {
                        break 'outer;
                    }
                }
            }
Editor is loading...
Leave a Comment