Add ReactNativeUnifiedPlan

src/handlers/ReactNativeUnifiedPlan.ts

@@ -330,6 +330,7 @@ export class ReactNativeUnifiedPlan extends HandlerInterface {
 		encodings,
 		codecOptions,
 		codec,
+		onRtpSender,
 	}: HandlerSendOptions): Promise<HandlerSendResult> {
 		this.assertNotClosed();
 		this.assertSendDirection();
@@ -368,6 +369,11 @@ export class ReactNativeUnifiedPlan extends HandlerInterface {
 			streams: [this._sendStream],
 			sendEncodings: encodings,
 		});
+
+		if (onRtpSender) {
+			onRtpSender(transceiver.sender);
+		}
+
 		let offer = await this._pc.createOffer();
 		let localSdpObject = sdpTransform.parse(offer.sdp);
 		let offerMediaObject;
@@ -884,6 +890,23 @@ export class ReactNativeUnifiedPlan extends HandlerInterface {
 
 		await this._pc.setRemoteDescription(offer);
 
+		for (const options of optionsList) {
+			const { trackId, onRtpReceiver } = options;
+
+			if (onRtpReceiver) {
+				const localId = mapLocalId.get(trackId);
+				const transceiver = this._pc
+					.getTransceivers()
+					.find((t: RTCRtpTransceiver) => t.mid === localId);
+
+				if (!transceiver) {
+					throw new Error('transceiver not found');
+				}
+
+				onRtpReceiver(transceiver.receiver);
+			}
+		}
+
 		let answer = await this._pc.createAnswer();
 		const localSdpObject = sdpTransform.parse(answer.sdp);