Skip to content

Commit 6baef07

Browse files
committed
Replace sender$ and receiver$ with transceiver$
1 parent cbd731d commit 6baef07

File tree

2 files changed

+10
-7
lines changed

2 files changed

+10
-7
lines changed

.changeset/mean-steaks-judge.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"partytracks": patch
3+
---
4+
5+
Replace sender$ and receiver$ with transceiver$

packages/partytracks/src/client/PartyTracks.ts

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -62,10 +62,9 @@ export class PartyTracks {
6262
peerConnection: RTCPeerConnection;
6363
sessionId: string;
6464
}>;
65-
#sender$: Subject<RTCRtpSender> = new ReplaySubject();
66-
sender$: Observable<RTCRtpSender> = this.#sender$.asObservable();
67-
#receiver$: Subject<RTCRtpReceiver> = new ReplaySubject();
68-
receiver$: Observable<RTCRtpReceiver> = this.#receiver$.asObservable();
65+
#transceiver$: Subject<RTCRtpTransceiver> = new ReplaySubject();
66+
transceiver$: Observable<RTCRtpTransceiver> =
67+
this.#transceiver$.asObservable();
6968
sessionError$: Observable<string>;
7069
peerConnectionState$: Observable<RTCPeerConnectionState>;
7170
config: PartyTracksConfig;
@@ -349,8 +348,7 @@ export class PartyTracks {
349348
direction: "sendonly"
350349
});
351350
logger.debug("🌱 creating transceiver!");
352-
this.#sender$.next(transceiver.sender);
353-
351+
this.#transceiver$.next(transceiver);
354352
return {
355353
transceiver,
356354
stableId,
@@ -452,7 +450,7 @@ export class PartyTracks {
452450
peerConnection,
453451
(t) => t.mid === pulledTrackData.mid
454452
).then((transceiver) => {
455-
this.#receiver$.next(transceiver.receiver);
453+
this.#transceiver$.next(transceiver);
456454
return transceiver.receiver.track;
457455
})
458456
});

0 commit comments

Comments
 (0)