在流中使用 map 时遇到 Dart 问题

Question

我创建了一个简单的流，添加一些元素并监听流。但是当我在流上使用地图时出现问题。为简单起见，我只是将值映射到相同的值（我猜？）。

当我尝试运行程序时出现地图错误：

Uncaught Error: TypeError: Instance of '_MapStream<String, dynamic>': type '_MapStream<String, dynamic>' is not a subtype of type 'Stream<String>'

import 'dart:async';

void main() async {

  StreamController controller = StreamController<String>.broadcast();

  final StreamTransformer transformer = StreamTransformer<String, String>.fromHandlers(
    handleData: (data, EventSink sink) {
        sink.add(data);
    }
  );
 
  Stream stream = controller.stream;

  stream
    .map((value) => value) // <-- Problem in this line
    .transform(transformer)
    .listen(
      (data) {
        print('listen: $data');
      },
      onError: (err) => print(err));
  
  controller.add('foo');
  controller.add('baa');

  controller.close();
}

Answer 1

您的问题是您从泛型类型中强制使用非泛型类型。如果您在不使用显式键入的情况下编写这样的代码：

import 'dart:async';

void main() async {
  final controller = StreamController<String>.broadcast(); // <-- fixed here

  final StreamTransformer transformer =
      StreamTransformer<String, String>.fromHandlers(
          handleData: (data, EventSink sink) {
    sink.add(data);
  });

  final stream = controller.stream;  // <-- fixed here

  stream
      .map((value) => value) // <-- Problem in this line
      .transform(transformer)
      .listen((data) {
    print('listen: $data');
  }, onError: (err) => print(err));

  controller.add('foo');
  controller.add('baa');

  controller.close();
}

然后，Dart 将自动确定类型是 StreamController<String> 和 Stream<String>，而不是您正在强制执行的 StreamController 和 Stream。

当您删除类型的泛型部分时，您也删除了 Dart 猜测您正在调用的所有方法的类型的能力。

如果使用显式类型，你应该写：

import 'dart:async';

void main() async {
  StreamController<String> controller = StreamController<String>.broadcast();

  final StreamTransformer transformer =
      StreamTransformer<String, String>.fromHandlers(
          handleData: (data, EventSink sink) {
    sink.add(data);
  });

  Stream<String> stream = controller.stream;

  stream
      .map((value) => value) // <-- Problem in this line
      .transform(transformer)
      .listen((data) {
    print('listen: $data');
  }, onError: (err) => print(err));

  controller.add('foo');
  controller.add('baa');

  controller.close();
}