代码之家 › 专栏 › 技术社区 › Ramesh-X Wen-Shan Wendy Chow

如何转换Stream<T?>流式传输<T>

dart

Ramesh-X Wen-Shan Wendy Chow · 技术社区 · 3 年前

我有以下函数将返回 int? 通过接受 String .

int? convert(String s) {
  // Some implementation
}

然后我有一个函数,它将转换为 Stream<String> 到 Stream<int> 。我目前的实现如下。

Stream<int> convertStream(Stream<String> s) {
  return s
    .map<int?>((i) => convert(i))
    .where((i) => i!=null)
    .map<int>((i) => i!);
}

这种方式对我来说不太好。还有其他方法可以用来实现同样的行为吗?

0 回复 | 直到 1 年前

Alexandre Ardhuin 3 年前

你的代码是正确的。

不像 Iterable , Stream 没有 whereType 方法。所以你做不到 s.map(convert).whereType<int>() .

您可以替换 .map<int>((i) => i!) 通过 .cast<int>() .

或者,您可以使用 async* 方法:

Stream<int> convertStream(Stream<String> input) async* {
  await for (var s in input) {
    var i = convert(s);
    if (i != null) {
      yield i;
    }
  }
}

编辑:根据@lrn的建议,您也可以使用 expand :

stream.expand<int>((int? v) => v == null ? [] : [v])

keplerian 3 年前

或者,您可以使用 whereType<T>() 在 stream_transform Dart-dev包,如下所示:

import 'package:stream_transform/stream_transform.dart';

Stream<int> convertStream(Stream<String> s) {
  return s
    .map<int?>((i) => convert(i))
    .whereType<int>(); // <--
}

推荐文章

swastij · 如何在颤振中创建垂直线性梯度?

2 年前

Jaimin Modi · 从Flutter中的Head呼叫响应中获取特定Header值

2 年前

Andrii Havryliak · 如何仅对需要状态的数组对象求和(true)

2 年前

IshikiHIkaru · 颤振:替换“.jpg”后面的特定字符串

2 年前

Tindona · 在flatter中有没有办法将响应体转换为XML?

2 年前

swapnil mane · 当我在颤振中向下滚动时,额定值变为零

2 年前

Aneesh A · 如何在flatter/dart中删除字符串中的空格,并将每个单词的第一个字母大写

2 年前

Irfan Ganatra · 颤振:如何在导航时知道参数是否传递

2 年前

Nikita · 如果有不好的状态还有些别的东西

2 年前

Tindona · 在flatter中更新小部件之间的值

2 年前