Flutter生命周期监听插件did_change_dependencies的使用

Flutter生命周期监听插件did_change_dependencies的使用

作者：Petrus Nguyễn Thái Học

译者：（无需翻译）

did_change_dependencies 插件提供了一个 Stream，当 State.didChangeDependencies 被首次调用时，该 Stream 会发出一个空值并完成事件。

示例

import 'dart:async';

import 'package:did_change_dependencies/did_change_dependencies.dart';
import 'package:flutter/material.dart';
import 'package:rxdart_ext/rxdart_ext.dart';

class Bloc {
  Stream<String> message$ = Stream.empty(); // 仅作演示
}

class MyPage extends StatefulWidget {
  const MyPage({Key? key}) : super(key: key);

  [@override](/user/override)
  _MyPageState createState() => _MyPageState();
}

class _MyPageState extends State<MyPage> with DidChangeDependenciesStream {
  final bloc = Bloc();
  final subscriptions = <StreamSubscription<void>>[];

  [@override](/user/override)
  void initState() {
    super.initState();

    final handle = (String msg) {
      // 安全地访问 ScaffoldMessengerState。
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(content: Text(msg)),
      );
    };
    subscriptions << 
        didChangeDependencies$
            .exhaustMap((value) => bloc.message$)
            .listen(handle);

    subscriptions << 
        didChangeDependencies$.listen((event) {
          // 当 `didChangeDependencies` 首次被调用时执行某些操作。
        });
  }

  [@override](/user/override)
  void dispose() {
    super.dispose();
    subscriptions.forEach((s) => s.cancel());
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Container();
  }
}

extension _ListExt<T> on List<T> {
  // 忽略此元素
  void operator <<(T t) => add(t);
}

代码解释

1. Bloc 类:

   class Bloc {
     Stream<String> message$ = Stream.empty(); // 仅作演示
   }
   

   这里定义了一个简单的 Bloc 类，其中包含一个空的 Stream<String>，用于演示目的。

2. MyPage 类:

   class MyPage extends StatefulWidget {
     const MyPage({Key? key}) : super(key: key);
   
     [@override](/user/override)
     _MyPageState createState() => _MyPageState();
   }
   

   这是一个简单的 StatefulWidget，其状态由 _MyPageState 管理。

3. _MyPageState 类:

   class _MyPageState extends State<MyPage> with DidChangeDependenciesStream {
     final bloc = Bloc();
     final subscriptions = <StreamSubscription<void>>[];
   

   _MyPageState 继承自 State<MyPage> 并混入了 DidChangeDependenciesStream。这里定义了 Bloc 实例和订阅列表。

4. initState 方法:

   [@override](/user/override)
   void initState() {
     super.initState();
   
     final handle = (String msg) {
       // 安全地访问 ScaffoldMessengerState。
       ScaffoldMessenger.of(context).showSnackBar(
         SnackBar(content: Text(msg)),
       );
     };
     subscriptions << 
         didChangeDependencies$
             .exhaustMap((value) => bloc.message$)
             .listen(handle);
   
     subscriptions << 
         didChangeDependencies$.listen((event) {
           // 当 `didChangeDependencies` 首次被调用时执行某些操作。
         });
   }
   

   在 initState 中，我们初始化了一些订阅。didChangeDependencies$ 是 Stream，当 didChangeDependencies 被首次调用时，它会发出事件。exhaustMap 操作符确保在每次 didChangeDependencies 被调用时，只处理最新的 bloc.message$ 流。另一个订阅用于处理 didChangeDependencies 的事件。

5. dispose 方法:

   [@override](/user/override)
   void dispose() {
     super.dispose();
     subscriptions.forEach((s) => s.cancel());
   }
   

   在 dispose 方法中，取消所有订阅以避免内存泄漏。

6. build 方法:

   [@override](/user/override)
   Widget build(BuildContext context) {
     return Container();
   }