Method read_from

debugger/src/event.rs:21–91

(source: Bytes)

impl EventStream {
    pub fn read_from(source: Bytes) -> Event {
        let mut reader = Reader::new();
        assert!(source.len() > 0);
        let event = match source.get(0) {
            b'B' => {
                let mut i = 1;
                let reason = match source.get(i) {
                    b'B' => crate::Reason::Breakpoint,
                    b'P' => crate::Reason::Panic,
                    b'F' => {
                        i += 1;
                        match source.get(i) {
                            b'{' => crate::Reason::FutureEnter,
                            b'}' => crate::Reason::FutureExit,
                            other => panic!("Unknown reason, got {other:?}"),
                        }
                    }
                    other => panic!("Unknown reason, got {other:?}"),
                };
                i += 1;
                reader.set_source(source, i);
                let breakpoint_id = reader.read_int().unwrap() as u32;
                let thread_id = reader.read_int().unwrap();
                let frame_id = reader.read_int().unwrap();
                let locals = reader.read_values();
                Event::Breakpoint {
                    breakpoint_id,
                    thread_id,
                    frame_id,
                    reason,
                    locals,
                }
            }
            b'F' => {
                reader.set_source(source, 1);
                let breakpoint_id = reader.read_int().unwrap() as u32;
                let thread_id = reader.read_int().unwrap();
                let frame_id = reader.read_int().unwrap();
                let stack_pointer = reader.read_int().unwrap();
                let function_name = reader.read_string().unwrap();
                let arguments = reader.read_values();
                Event::FunctionCall {
                    breakpoint_id,
                    thread_id,
                    frame_id,
                    stack_pointer,
                    function_name,
                    arguments,
                }
            }
            b'R' => {
                reader.set_source(source, 1);
                let breakpoint_id = reader.read_int().unwrap() as u32;
                let thread_id = reader.read_int().unwrap();
                let frame_id = reader.read_int().unwrap();
                let function_name = reader.read_string().unwrap();
                let mut values = reader.read_values();
                let (name, return_value) = values.remove(0);