fix: can not call startDirectCdnStreaming again after stopDirectCdnSt…

…reaming
AgoraIO-Extensions · Apr 19, 2023 · ce9fa44 · ce9fa44
1 parent a250211
commit ce9fa44
Showing 1 changed file with 23 additions and 3 deletions.
diff --git a/lib/src/impl/agora_rtc_engine_impl.dart b/lib/src/impl/agora_rtc_engine_impl.dart
@@ -182,6 +182,8 @@ class RtcEngineImpl extends rtc_engine_ex_binding.RtcEngineExImpl
 
   final ScopedObjects _objectPool = ScopedObjects();
 
+  DirectCdnStreamingEventHandlerWrapper? _directCdnStreamingEventHandlerWrapper;
+
   @internal
   late MethodChannel engineMethodChannel;
 
@@ -558,7 +560,7 @@ class RtcEngineImpl extends rtc_engine_ex_binding.RtcEngineExImpl
       {required DirectCdnStreamingEventHandler eventHandler,
       required String publishUrl,
       required DirectCdnStreamingMediaOptions options}) async {
-    final eventHandlerWrapper =
+    _directCdnStreamingEventHandlerWrapper =
         DirectCdnStreamingEventHandlerWrapper(eventHandler);
     final param =
         createParams({'publishUrl': publishUrl, 'options': options.toJson()});
@@ -567,11 +569,29 @@ class RtcEngineImpl extends rtc_engine_ex_binding.RtcEngineExImpl
         ScopedEvent(
             scopedKey: _rtcEngineImplScopedKey,
             registerName: 'RtcEngine_startDirectCdnStreaming',
-            unregisterName: '',
-            handler: eventHandlerWrapper),
+            unregisterName: 'RtcEngine_stopDirectCdnStreaming',
+            handler: _directCdnStreamingEventHandlerWrapper!),
         jsonEncode(param));
   }
 
+  @override
+  Future<void> stopDirectCdnStreaming() async {
+    if (_directCdnStreamingEventHandlerWrapper == null) {
+      return;
+    }
+
+    final param = createParams({});
+    await irisMethodChannel.unregisterEventHandler(
+        ScopedEvent(
+            scopedKey: _rtcEngineImplScopedKey,
+            registerName: 'RtcEngine_startDirectCdnStreaming',
+            unregisterName: 'RtcEngine_stopDirectCdnStreaming',
+            handler: _directCdnStreamingEventHandlerWrapper!),
+        jsonEncode(param));
+
+    _directCdnStreamingEventHandlerWrapper = null;
+  }
+
   @override
   VideoDeviceManager getVideoDeviceManager() {
     return VideoDeviceManagerImpl.create(this);