Move observeInboundRtpStreamStats$ into the appropriate file

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,

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),
+  );
+}