Flutter多功能辅助插件jovial_misc_native的使用

Flutter 多功能辅助插件 jovial_misc_native 的使用

介绍

jovial_misc_native 是一组用于 Dart 语言的小型实用工具。这些工具主要用于无法在 Web/JavaScript 平台上运行的场景。该插件主要为个人使用而创建，但您可以自由使用它。此插件从 jovial_misc 分离出来，以明确在 pub.dev 列表中其余部分可以在 JavaScript 上正常工作。本插件按照 MIT 许可证提供。

使用

数据 I/O 流示例

以下示例展示了如何使用 FlushingIOSink、DataOutputSink 和 DataInputStream 来处理与 java.io.DataInputStream 和 java.io.DataOutputStream 兼容的数据。

import 'dart:async';
import 'dart:io';
import 'package:intl/intl.dart';
import 'package:jovial_misc/io_utils.dart';
import 'package:jovial_misc_native/io_utils_native.dart';
import 'package:jovial_misc_native/isolate_stream.dart';

///
/// 示例：使用 [FlushingIOSink]、[DataOutputSink] 和 [DataInputStream]
/// 来处理与 `java.io.DataInputStream` 和 `java.io.DataOutputStream` 兼容的数据。
///
Future<void> dataIoStreamExample() async {
  // 创建一个临时文件
  final file = File.fromUri(Directory.systemTemp.uri.resolve('test.dat'));
  // 打开文件写入流
  final sink = FlushingIOSink(file.openWrite());
  // 将数据输出流包装到文件写入流
  final out = DataOutputSink(sink);
  // 写入 UTF-8 编码的字符串
  out.writeUTF8('Hello, world.');
  // 异步关闭流
  unawaited(sink.close());
  // 等待关闭完成
  await sink.done;

  // 打开文件读取流
  final dis = DataInputStream(file.openRead());
  // 读取并打印 UTF-8 编码的字符串
  print(await dis.readUTF8());
  // 关闭读取流
  await dis.close();
  // 删除临时文件
  await file.delete();
}

隔离流示例

以下示例展示了如何使用 IsolateStream 在单独的隔离中运行计算密集型生成器函数。我们使用 FizzBuzz 作为计算密集型值序列的代表。

///
/// 示例：使用 [IsolateStream] 在单独的隔离中运行计算密集型生成器函数。
///
Future<void> isolateStreamExample() async {
  const max = 25;
  final fmt = NumberFormat();
  const iterationPause = Duration(milliseconds: 250);
  print('Generating FizzBuzz sequence up to ${fmt.format(max)}');

  // 创建一个隔离流
  final stream = IsolateStream<String>(FizzBuzzGenerator(max));
  // 我们的流将限制缓冲区最多容纳 11 个字符串
  for (var iter = StreamIterator(stream); await iter.moveNext();) {
    print(iter.current);
    await Future<void>.delayed(iterationPause);
  }
  // 注意，生产者不会远远领先于消费者，因为缓冲区限制为最多 7 个条目
}

/// 在单独的隔离中运行的生成器类
class FizzBuzzGenerator extends IsolateStreamGenerator<String> {
  final int _max;

  FizzBuzzGenerator(this._max) {
    print('FizzBuzzGenerator 构造函数。注意，这只会运行一次。');
    // 这演示了当 FizzBuzzGenerator 被发送到另一个隔离时，接收隔离不会运行构造函数。
  }

  [@override](/user/override)
  Future<void> generate() async {
    for (var i = 1; i <= _max; i++) {
      var result = '';
      if (i % 3 == 0) {
        result = 'Fizz';
      }
      if (i % 5 == 0) {
        result += 'Buzz';
      }
      print('        生成器发送 $i $result');
      if (result == '') {
        await sendValue(i.toString());
      } else {
        await sendValue(result);
      }
    }
  }

  [@override](/user/override)
  int sizeOf(String value) => 1; // 每个条目占用 1 个单位

  [@override](/user/override)
  int get bufferSize => 7; // 缓冲区最多容纳 7 个条目
}

///
/// 运行示例
///
void main() async {
  await dataIoStreamExample();
  print('');
  await isolateStreamExample();
}