fix:チャンネルを閉じるように修正

GreenTeaProgrammers · Feb 23, 2024 · 1a060a6 · 1a060a6
1 parent fd6ed0e
commit 1a060a6
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/frontend/where_child_bus/lib/pages/camera_page/camera_page.dart b/frontend/where_child_bus/lib/pages/camera_page/camera_page.dart
@@ -37,6 +37,9 @@ class _CameraPageState extends State<CameraPage> {
   VehicleEvent _vehicleEvent = VehicleEvent.VEHICLE_EVENT_GET_ON;
   final Location location = Location();
 
+  ClientChannel? _videoChannel;
+  ClientChannel? _locationChannel;
+
   @override
   void initState() {
     super.initState();
@@ -70,12 +73,12 @@ class _CameraPageState extends State<CameraPage> {
 
   Future<void> streamBusVideo(
       Stream<StreamBusVideoRequest> requestStream) async {
-    final channel = ClientChannel(
+    _videoChannel = ClientChannel(
       appConfig.grpcEndpoint,
       port: appConfig.grpcPort,
       options: const ChannelOptions(),
     );
-    final grpcClient = BusServiceClient(channel);
+    final grpcClient = BusServiceClient(_videoChannel!);
     developer.log("ServiceClient created");
     final res = grpcClient.streamBusVideo(requestStream);
 
@@ -87,18 +90,18 @@ class _CameraPageState extends State<CameraPage> {
     } catch (error) {
       developer.log("Caught Error:", error: error, name: "StreamBusVideo");
     } finally {
-      await channel.shutdown();
+      await _videoChannel!.shutdown();
     }
   }
 
   Future<void> _streamCoordinate(
       Stream<SendLocationContinuousRequest> requestStream) async {
-    final channel = ClientChannel(
+    _locationChannel = ClientChannel(
       appConfig.grpcEndpoint,
       port: appConfig.grpcPort,
       options: const ChannelOptions(),
     );
-    final grpcClient = BusServiceClient(channel);
+    final grpcClient = BusServiceClient(_locationChannel!);
     developer.log("ServiceClient created");
     final res = grpcClient.sendLocationContinuous(requestStream);
 
@@ -109,7 +112,7 @@ class _CameraPageState extends State<CameraPage> {
     } catch (error) {
       developer.log("Caught Error:", error: error);
     } finally {
-      await channel.shutdown();
+      await _locationChannel!.shutdown();
     }
   }
 
@@ -282,6 +285,8 @@ class _CameraPageState extends State<CameraPage> {
     _controller.dispose();
     _streamController.close();
     _locationStream.close();
+    _videoChannel?.shutdown();
+    _locationChannel?.shutdown();
     super.dispose();
   }