small fix

rerun-io · Dec 19, 2024 · c471836 · c471836
1 parent af6c0dd
commit c471836
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/rerun_py/src/remote.rs b/rerun_py/src/remote.rs
@@ -97,7 +97,7 @@ impl PyStorageNodeClient {
                 .await
                 .map_err(|err| PyRuntimeError::new_err(err.to_string()))?
                 .into_inner()
-                .filter_map(|resp| {
+                .map(|resp| {
                     resp.and_then(|r| {
                         decode(r.encoder_version(), &r.payload)
                             .map_err(|err| tonic::Status::internal(err.to_string()))
@@ -185,7 +185,7 @@ impl PyStorageNodeClient {
                 .map_err(|err| PyRuntimeError::new_err(err.to_string()))?
                 .into_inner();
             let metadata = decode(resp.encoder_version(), &resp.payload)
-                .map_err(|err| PyRuntimeError::new_err(err.to_string()))?
+                .map_err(|err| PyRuntimeError::new_err(err.to_string()))?;
 
             let recording_id = metadata
                 .all_columns()
@@ -294,10 +294,6 @@ impl PyStorageNodeClient {
                 let tc = decode(EncoderVersion::V0, &response.payload)
                     .map_err(|err| PyRuntimeError::new_err(err.to_string()))?;
 
-                let Some(tc) = tc else {
-                    return Err(PyRuntimeError::new_err("Stream error"));
-                };
-
                 let chunk = Chunk::from_transport(&tc)
                     .map_err(|err| PyRuntimeError::new_err(err.to_string()))?;