stream - 如何在 Dart 中创建 StreamTransformer？

Question

尝试构建一个自定义 StreamTransformer 类，但是许多示例似乎已经过时，并且文档中找到的示例不是(某些类型语言可能会考虑的)作为一个类(发现此处:https://api.dartlang.org/apidocs/channels/stable/dartdoc-viewer/dart:async.StreamTransformer)。这看起来不像是一种非常类似于 Dart 的方法，而是更像是一种类似于 Javascript 的方法(我使用 Dart 来避免这种方式)。

许多在线资源都说这就是创建 StreamTransformer 的方式，但是在扩展它时会出现错误。

class exampleStreamTransformer extends StreamTransformer
{
  //... (This won't work)
}

“实现”似乎是可行的方法，同时实现所需的绑定(bind)功能:

class exampleStreamTransformer implements StreamTransformer
{
  Stream bind(Stream stream)
  {
    //... (Go on to return new stream, etc)
  }
}

我似乎找不到这种方式的任何示例，但我自己把一些东西放在一起(这在我的 IDE 中被接受，但在运行时不被接受，当它尝试使用暂停时，我收到一个空对象错误 setter/getter ):

class exampleStreamTransformer implements StreamTransformer
{
  StreamController<String> _controller;
  StreamSubscription<String> _subscription;

  Stream bind(Stream stream)
  {
    _controller = new StreamController<String>(
        onListen: ()
        {
          _subscription = stream.listen((data)
          {
            // Transform the data.
            _controller.add(data);
          },
          onError: _controller.addError,
          onDone: _controller.close,
          cancelOnError: true); // Unsure how I'd pass this in?????
        },
        onPause: _subscription.pause,
        onResume: _subscription.resume,
        onCancel: _subscription.cancel,
        sync: true
    );

    return _controller.stream;
  }
}

希望以这种方式实现它，就像以“类型化”方式生成类(class)一样，非常感谢任何帮助，谢谢。

Answer 1

为什么不使用StreamTransformer.fromHandler():

import 'dart:async';

void handleData(data, EventSink sink) {
  sink.add(data*2);
}

void main() {
  StreamTransformer doubleTransformer = new StreamTransformer.fromHandlers(handleData: handleData);

  StreamController controller = new StreamController();
  controller.stream.transform(doubleTransformer).listen((data) {
    print('data: $data');
  });

  controller.add(1);
  controller.add(2);
  controller.add(3);
}

输出:

data: 2
data: 4
data: 6