fix clean up

Author: hiroshihorie

lib/src/core/room.dart

@@ -180,6 +180,8 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
     onDispose(() async {
       // clean up routine
       await _cleanUp();
+      // dispose preConnectAudioBuffer
+      await preConnectAudioBuffer.dispose();
       // dispose events
       await events.dispose();
       // dispose local participant
@@ -452,7 +454,7 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
           publishOptions: roomOptions.defaultAudioPublishOptions.copyWith(preConnect: true),
         );
       }
-      
+
       if (connectOptions.protocolVersion.index >= ProtocolVersion.v8.index &&
           engine.fastConnectOptions != null &&
           !engine.fullReconnectOnNext) {
@@ -977,7 +979,7 @@ extension RoomPrivateMethods on Room {
 
     _activeSpeakers.clear();
 
-    await preConnectAudioBuffer.dispose();
+    await preConnectAudioBuffer.reset();
 
     // clean up engine
     await engine.cleanUp();

lib/src/events.dart

@@ -609,13 +609,13 @@ class PreConnectAudioBufferStartedEvent with RoomEvent {
 /// Emitted by [Room].
 class PreConnectAudioBufferStoppedEvent with RoomEvent {
   final int bufferedSize;
-  final bool isDataSent;
+  final bool isBufferSent;
   const PreConnectAudioBufferStoppedEvent({
     required this.bufferedSize,
-    required this.isDataSent,
+    required this.isBufferSent,
   });
 
   @override
   String toString() => '${runtimeType}'
-      '(bufferedSize: ${bufferedSize}, isDataSent: ${isDataSent})';
+      '(bufferedSize: ${bufferedSize}, isDataSent: ${isBufferSent})';
 }

lib/src/preconnect/pre_connect_audio_buffer.dart

@@ -33,7 +33,7 @@ class PreConnectAudioBuffer {
 
   // Internal states
   bool _isRecording = false;
-  bool _isSent = false;
+  bool _isBufferSent = false;
   String? _rendererId;
 
   LocalAudioTrack? _localTrack;
@@ -167,7 +167,7 @@ class PreConnectAudioBuffer {
     // Emit the stopped event
     _room.events.emit(PreConnectAudioBufferStoppedEvent(
       bufferedSize: _buffer.length,
-      isDataSent: _isSent,
+      isBufferSent: _isBufferSent,
     ));
 
     logger.info('[Preconnect audio] stopped recording');
@@ -188,32 +188,22 @@ class PreConnectAudioBuffer {
     _localTrackPublishedEvent = null;
 
     // Reset the _isSent flag to allow data sending on next use
-    _isSent = false;
+    _isBufferSent = false;
 
     logger.info('[Preconnect audio] reset');
   }
 
   // Dispose the audio buffer and clean up all resources.
   Future<void> dispose() async {
-    // Ensure we stop recording first
-    await stopRecording();
-
-    // Don't stop the local track - it will continue to be used by the Room
-    _localTrack = null;
-
-    _agentReadyManager.dispose();
-    _timeoutTimer?.cancel();
-    _participantStateListener?.call();
-    _participantStateListener = null;
-
+    await reset();
     logger.info('[Preconnect audio] disposed');
   }
 
   Future<void> sendAudioData({
     required List<String> agents,
     String topic = dataTopic,
   }) async {
-    if (_isSent) return;
+    if (_isBufferSent) return;
     if (agents.isEmpty) return;
 
     // Wait for local track published event
@@ -231,7 +221,7 @@ class PreConnectAudioBuffer {
     final data = _buffer.takeBytes();
     logger.info('[Preconnect audio] data.length: ${data.length}, bytes.length: ${_buffer.length}');
 
-    _isSent = true;
+    _isBufferSent = true;
 
     final streamOptions = StreamBytesOptions(
       topic: topic,