From 9930288d1f43254521a1e213de29d03929d37ab7 Mon Sep 17 00:00:00 2001
From: Robin <robin@robin.town>
Date: Fri, 27 Feb 2026 17:08:04 +0100
Subject: [PATCH] Move observeInboundRtpStreamStats$ into the appropriate file

---
 src/state/media/MemberMediaViewModel.ts  | 11 +----------
 src/state/media/observeRtpStreamStats.ts | 10 ++++++++++
 2 files changed, 11 insertions(+), 10 deletions(-)

diff --git a/src/state/media/MemberMediaViewModel.ts b/src/state/media/MemberMediaViewModel.ts
index de64d93b..b7c2549d 100644
--- a/src/state/media/MemberMediaViewModel.ts
+++ b/src/state/media/MemberMediaViewModel.ts
@@ -37,7 +37,7 @@ import { type EncryptionSystem } from "../../e2ee/sharedKeyManagement";
 import { type ObservableScope } from "../ObservableScope";
 import { observeTrackReference$ } from "../observeTrackReference";
 import { E2eeType } from "../../e2ee/e2eeType";
-import { observeRtpStreamStats$ } from "./observeRtpStreamStats";
+import { observeInboundRtpStreamStats$ } from "./observeRtpStreamStats";
 
 export enum EncryptionStatus {
   Connecting,
@@ -181,15 +181,6 @@ export function createMemberMedia(
   };
 }
 
-function observeInboundRtpStreamStats$(
-  participant: Participant,
-  source: Track.Source,
-): Observable<RTCInboundRtpStreamStats | undefined> {
-  return observeRtpStreamStats$(participant, source, "inbound-rtp").pipe(
-    map((x) => x as RTCInboundRtpStreamStats | undefined),
-  );
-}
-
 function encryptionErrorObservable$(
   room$: Behavior<LivekitRoom | undefined>,
   participant: Participant,
diff --git a/src/state/media/observeRtpStreamStats.ts b/src/state/media/observeRtpStreamStats.ts
index 695edc65..d1640382 100644
--- a/src/state/media/observeRtpStreamStats.ts
+++ b/src/state/media/observeRtpStreamStats.ts
@@ -18,6 +18,7 @@ import {
   type Observable,
   startWith,
   switchMap,
+  map,
 } from "rxjs";
 
 import { observeTrackReference$ } from "../observeTrackReference";
@@ -57,3 +58,12 @@ export function observeRtpStreamStats$(
     startWith(undefined),
   );
 }
+
+export function observeInboundRtpStreamStats$(
+  participant: Participant,
+  source: Track.Source,
+): Observable<RTCInboundRtpStreamStats | undefined> {
+  return observeRtpStreamStats$(participant, source, "inbound-rtp").pipe(
+    map((x) => x as RTCInboundRtpStreamStats | undefined),
+  );
+}