diff --git a/data_only_viz/iphone_usb_source.py b/data_only_viz/iphone_usb_source.py
new file mode 100644
index 0000000..b6c2601
--- /dev/null
+++ b/data_only_viz/iphone_usb_source.py
@@ -0,0 +1,97 @@
+"""IphoneUSBSource — a cv2-VideoCapture-shaped frame source backed by the
+iPhone ARBodyTracker USB stream. Decodes the AVLiveWire HEVC video to BGR
+frames for MediaPipe, and (Task 2) writes ARKit skeleton + Vision hands into
+State. Substitutes for cv2.VideoCapture in multi.py under --iphone-usb."""
+from __future__ import annotations
+
+import logging
+import threading
+import time
+
+import av
+import cv2
+import numpy as np
+
+from data_only_viz.scripts.iphone_usb_bridge import (
+    connect_device, iter_frames, TAG_SKELETON,
+)
+
+TAG_VIDEO = 2
+TAG_HANDS = 4
+LOG = logging.getLogger("iphone_usb_source")
+
+
+def _to_annexb(data: bytes) -> bytes:
+    out = bytearray(); i = 0
+    while i + 4 <= len(data):
+        n = int.from_bytes(data[i:i + 4], "big"); i += 4
+        if i + n > len(data):
+            break
+        out += b"\x00\x00\x00\x01" + data[i:i + n]; i += n
+    return bytes(out)
+
+
+class IphoneUSBSource:
+    def __init__(self, state=None, target_size=(640, 480)) -> None:
+        self.state = state
+        self.target_w, self.target_h = target_size
+        self._codec = av.codec.CodecContext.create("hevc", "r")
+        self._lock = threading.Lock()
+        self._frame = None            # latest BGR np.ndarray
+        self._stop = threading.Event()
+        self._thread = None
+        self._opened = False
+
+    def start(self) -> bool:
+        sock = connect_device()
+        if sock is None:
+            LOG.error("iphone usb: no device / connect failed")
+            return False
+        self._opened = True
+        self._thread = threading.Thread(
+            target=self._run, args=(sock,), name="iphone_usb_src", daemon=True)
+        self._thread.start()
+        return True
+
+    def isOpened(self) -> bool:
+        return self._opened
+
+    def _run(self, sock) -> None:
+        try:
+            for tag, pid, payload in iter_frames(sock):
+                if self._stop.is_set():
+                    break
+                if tag == TAG_VIDEO and len(payload) > 1:
+                    annexb = _to_annexb(payload[1:])
+                    try:
+                        for fr in self._codec.decode(av.Packet(annexb)):
+                            img = fr.to_ndarray(format="bgr24")
+                            img = cv2.resize(img, (self.target_w, self.target_h))
+                            with self._lock:
+                                self._frame = img
+                    except av.AVError as e:
+                        LOG.debug("hevc decode: %s", e)
+                # skeleton + hands handled in Task 2
+        except OSError as e:
+            LOG.warning("iphone usb stream ended: %s", e)
+        finally:
+            try:
+                sock.close()
+            except OSError:
+                pass
+            self._opened = False
+
+    def read(self):
+        with self._lock:
+            if self._frame is None:
+                return False, None
+            return True, self._frame.copy()
+
+    def set(self, *args) -> bool:
+        return True   # cv2 CAP_PROP_* no-op
+
+    def release(self) -> None:
+        self._stop.set()
+        if self._thread is not None:
+            self._thread.join(timeout=2.0)
+        self._opened = False