Use data store

.vscode/launch.json

@@ -42,6 +42,25 @@
             ],
             "cwd": "${workspaceFolder}"
         },
+        {
+            "name": "Debug 'nyud'",
+            "type": "lldb",
+            "request": "launch",
+            "cargo": {
+                "args": [
+                    "build",
+                    "--package=nyud"
+                ],
+                "filter": {
+                    "name": "nyud",
+                    "kind": "bin"
+                }
+            },
+            "args": [
+                "nyud/dataset/cafe.zip"
+            ],
+            "cwd": "${workspaceFolder}"
+        },
         {
             "name": "Debug 'prototype' tests",
             "type": "lldb",

CHANGELOG.md

@@ -1,7 +1,8 @@
 # rerun changelog
 
-A crude, incomplete, reverse time-line of user-facing things added, removed and changed.
+A crude and incomplete time-line of user-facing things added, removed and changed. Newest on top.
 
+* 2022-06-15: Add support for batch logging ([#13](https://github.com/rerun-io/rerun/pull/13)).
 * 2022-05-12: Click on a point to center camera on that point in the 3D view.
 * 2022-05-12: Use WSAD and QE to move camera in 3D view.
 * 2022-05-09: Step forward/back in time with arrow keys.

Cargo.toml

@@ -4,6 +4,7 @@ members = [
     "comms",
     "data_store",
     "log_types",
+    "nyud",
     "objectron",
     "rr_string_interner",
     "viewer",

comms/src/server.rs

@@ -1,11 +1,13 @@
-use futures_util::{SinkExt, StreamExt};
-use log_types::LogMsg;
-use parking_lot::Mutex;
 use std::sync::Arc;
 use std::{net::SocketAddr, time::Duration};
+
+use futures_util::{SinkExt, StreamExt};
+use parking_lot::Mutex;
 use tokio::net::{TcpListener, TcpStream};
 use tokio_tungstenite::{accept_async, tungstenite::Error};
 
+use log_types::LogMsg;
+
 // ----------------------------------------------------------------------------
 
 pub struct Server {
@@ -131,10 +133,10 @@ async fn handle_connection(
                     }
                 }
             }
-            log_msg = log_rx.recv() => {
-                let log_msg = log_msg.unwrap();
+            data_msg = log_rx.recv() => {
+                let data_msg = data_msg.unwrap();
 
-                ws_sender.send(tungstenite::Message::Binary(log_msg.to_vec())).await?;
+                ws_sender.send(tungstenite::Message::Binary(data_msg.to_vec())).await?;
             }
             _ = interval.tick() => {
                 // ws_sender.send(Message::Text("tick".to_owned())).await?;

data_store/Cargo.toml

@@ -11,10 +11,14 @@ publish = false
 log_types = { path = "../log_types" }
 
 ahash = "0.7"
-im = "15"
+itertools = "0.10"
 nohash-hasher = "0.2"
 tracing = "0.1"
 
+# native:
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+puffin = { version = "0.13", optional = true }
+
 [dev-dependencies]
 criterion = "0.3"
 mimalloc = "0.1"