Protocol cleanup (9): stream packetization

Author: zmerp

Cargo.lock

@@ -3,7 +3,7 @@ resolver = "2"
 members = ["alvr/*"]
 
 [workspace.package]
-version = "21.0.0-dev10"
+version = "21.0.0-dev11"
 edition = "2024"
 rust-version = "1.88"
 authors = ["alvr-org"]

Cargo.toml

@@ -302,7 +302,7 @@ pub fn record_audio_blocking(
 
                 if is_running() {
                     let mut buffer = sender.get_buffer(&()).unwrap();
-                    buffer.get_range_mut(0, data.len()).copy_from_slice(&data);
+                    buffer.get_range_mut(0..data.len()).copy_from_slice(&data);
                     sender.send(buffer).ok();
                 } else {
                     *state.lock() = AudioRecordState::ShouldStop;

alvr/audio/src/lib.rs

@@ -245,7 +245,7 @@ fn create_speaker_stream(
                     // no need to do conversions
                     let mut buffer = sender.get_buffer(&()).unwrap();
                     buffer
-                        .get_range_mut(0, size)
+                        .get_range_mut(0..size)
                         .copy_from_slice(&data[0..size]);
                     sender.send(buffer).ok();
                 }

alvr/audio/src/linux.rs

@@ -78,7 +78,7 @@ pub fn record_audio_blocking(
         while let Ok(sample_buffer) = samples_receiver.recv_timeout(INPUT_RECV_TIMEOUT) {
             let mut buffer = sender.get_buffer(&()).unwrap();
             buffer
-                .get_range_mut(0, sample_buffer.len())
+                .get_range_mut(0..sample_buffer.len())
                 .copy_from_slice(&sample_buffer);
             sender.send(buffer).ok();
         }

alvr/client_core/src/audio.rs

@@ -853,7 +853,7 @@ fn connection_pipeline(
                 let mut buffer = video_sender.get_buffer(&header).unwrap();
                 // todo: make encoder write to socket buffers directly to avoid copy
                 buffer
-                    .get_range_mut(0, payload.len())
+                    .get_range_mut(0..payload.len())
                     .copy_from_slice(&payload);
                 video_sender.send(buffer).ok();
             }