Flutter逻辑隔离插件isolated_logic的使用

Flutter逻辑隔离插件isolated_logic的使用

安装

稳定版:

dart pub add isolated_logic

特性

• 简便: 只需将现有的控制器包装起来即可使用。
• 解决方案无关: 支持任何可以发出状态的流式管理解决方案。
• 互操作性: 支持 StreamBuilders 和 ValueListenableBuilder。
• 低开销: 由于在隔离进程间进行序列化和反序列化，速度损失仅约5%。
• 单一抽象: 使用单一的 IsolatedController 抽象来处理多种业务逻辑方法。

使用

示例（BLoC 的包装器）

class PrimesBlocIsolated extends IsolatedController<PrimesBLoC, AppDependencies, PrimesEvent, int> {
  /// 创建目标控制器可以作为参数声明，也可以像 'super' 值一样传递；
  PrimesBlocIsolated({required super.createController});

  /// [controllerLifecycle] 描述了在分离的隔离进程中实例化的控制器的生命周期
  [@override](/user/override)
  ControllerLifecycleHandler<PrimesBLoC> get controllerLifecycle => ControllerLifecycleHandler(
        stateStream: (controller) => controller.stream,
        dispose: (controller) => controller.close(),
      );

  /// 这些事件将在分离的隔离进程中处理
  ///
  /// 通过总线，这些事件发出的所有状态都将路由到主隔离进程
  void increment() => isolateHandle((controller) => controller.add(const PrimesEvent.increment()));
  void decrement() => isolateHandle((controller) => controller.add(const PrimesEvent.decrement()));
}

示例代码

import 'dart:async';

import 'package:example/app_dependencies.dart';
import 'package:example/counter_bloc.dart';
import 'package:flutter/material.dart';
import 'package:http/http.dart';
import 'package:isolated_logic/isolated_logic.dart';

void main() async {
  await logicalHandler.init(
    observer: IsolatedControllerObserver.dartLog(),
    dependencies: AppDependencies(
      dependency: TransitiveDependency(httpClient: Client()),
    ),
  );

  runApp(
    const MyApp(),
  );
}

class MyApp extends StatelessWidget {
  const MyApp({super.key});

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        colorScheme: ColorScheme.fromSeed(seedColor: Colors.deepPurple),
        useMaterial3: true,
      ),
      home: const MyHomePage(title: 'Flutter Demo Home Page'),
    );
  }
}

class MyHomePage extends StatefulWidget {
  const MyHomePage({super.key, required this.title});

  final String title;

  [@override](/user/override)
  State<MyHomePage> createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  late final PrimesBLoC _counterMain = PrimesBLoC(TransitiveDependency(httpClient: Client()))
    ..stream.listen(_streamController.add);
  
  late final JsonBlocIsolated _counterIsolated =
      JsonBlocIsolated(createController: (deps) => PrimesBLoC(deps.dependency))..stream.listen(_streamController.add);

  final _streamController = StreamController.broadcast();
  late final stream = _streamController.stream;

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        backgroundColor: Theme.of(context).colorScheme.inversePrimary,
        title: Text(widget.title),
      ),
      body: StreamBuilder(
          stream: stream,
          builder: (context, data) => ListView.builder(
                itemBuilder: (context, index) => ListTile(
                  title: Text('${data.data}'),
                ),
              )),
      floatingActionButton: GestureDetector(
          onTap: () => _counterMain.add(const JsonEvent.increment()),
          onLongPress: _counterIsolated.increment,
          child: const DecoratedBox(
            decoration: BoxDecoration(color: Colors.greenAccent),
            child: Padding(padding: EdgeInsets.all(24), child: Icon(Icons.plus_one)),
          )),
    );
  }
}