update.

lib/src/core/engine.dart

@@ -422,7 +422,7 @@ class Engine extends Disposable with EventsEmittable<EngineEvent> {
                   'Timed out waiting for SignalResumedEvent'),
             );
           }
-          resumeConnection.call(null);
+          await resumeConnection.call(null);
         } catch (e) {
           logger.warning('Failed to resume connection: $e');
         }
@@ -702,9 +702,13 @@ class Engine extends Disposable with EventsEmittable<EngineEvent> {
     required lk_rtc.UpdateSubscription subscription,
     required Iterable<lk_rtc.TrackPublishedResponse>? publishTracks,
   }) async {
-    final answer = (await subscriber?.pc.getLocalDescription())?.toPBType();
+    final previousAnswer =
+        (await subscriber?.pc.getLocalDescription())?.toPBType();
+    final previousOffer =
+        (await publisher?.pc.getLocalDescription())?.toPBType();
     signalClient.sendSyncState(
-      answer: answer,
+      answer: previousAnswer,
+      offer: previousOffer,
       subscription: subscription,
       publishTracks: publishTracks,
       dataChannelInfo: dataChannelInfo(),
@@ -833,7 +837,7 @@ class Engine extends Disposable with EventsEmittable<EngineEvent> {
             'Received ${SignalTrickleEvent} but publisher or subscriber was null.');
         return;
       }
-      logger.fine('got ICE candidate from peer');
+      logger.fine('got ICE candidate from peer (target: ${event.target})');
       if (event.target == lk_rtc.SignalTarget.SUBSCRIBER) {
         await subscriber!.addIceCandidate(event.candidate);
       } else if (event.target == lk_rtc.SignalTarget.PUBLISHER) {
@@ -861,6 +865,10 @@ class Engine extends Disposable with EventsEmittable<EngineEvent> {
             reason: event.reason.toSDKType());
         await cleanUp();
       }
+    })
+    ..on<SignalResumedEvent>((event) async {
+      logger.fine('[$objectId] Signal resumed');
+      await resumeConnection.call(null);
     });
 }
 

lib/src/core/room.dart

@@ -659,8 +659,8 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
     );
   }
 
-  Future<void> _handlePostReconnect(bool isFullReconnect) async {
-    if (isFullReconnect) {
+  Future<void> _handlePostReconnect(bool rePublishAllTracks) async {
+    if (rePublishAllTracks) {
       // re-publish all tracks
       await localParticipant?.rePublishAllTracks();
     }

lib/src/core/signal_client.dart

@@ -475,13 +475,15 @@ extension SignalClientRequests on SignalClient {
   @internal
   void sendSyncState({
     required lk_rtc.SessionDescription? answer,
+    required lk_rtc.SessionDescription? offer,
     required lk_rtc.UpdateSubscription subscription,
     required Iterable<lk_rtc.TrackPublishedResponse>? publishTracks,
     required Iterable<lk_rtc.DataChannelInfo>? dataChannelInfo,
   }) =>
       _sendRequest(lk_rtc.SignalRequest(
         syncState: lk_rtc.SyncState(
           answer: answer,
+          offer: offer,
           subscription: subscription,
           publishTracks: publishTracks,
           dataChannels: dataChannelInfo,

lib/src/core/transport.dart

@@ -275,7 +275,6 @@ class Transport extends Disposable {
 
     try {
       final result = await pc.getRemoteDescription();
-      logger.fine('pc.getRemoteDescription $result');
       return result;
     } catch (_) {
       logger.warning('pc.getRemoteDescription failed with error: $_');