Dart中Iterable、Stream的糖语法

Iterable

setRange

将iterable跳过skipCount之后的值，依次赋值到本list的[start,end)上。

  
List<String> list = ["a", "b", "c", "d", "e"];
List<String> list2 = ["1", "2", "3", "4", "5"];
list.setRange(0, 2, list2, 2);
print(list);

//[3, 4, c, d, e]

sublist

返回list的[start, end)部分。

list方法中所有涉及到start、end参数的，都是[start, end)左闭右开的。

  
//list: [3, 4, c, d, e]
print(list.sublist(0, 2));

//[3, 4]

replaceRange

将list的[start, end)部分元素替换成replacement的元素。

  
//list: [3, 4, c, d, e]
list.replaceRange(0, 2, ["a", "b"]);
print(list);

//[a, b, c, d, e]

retainWhere

只保留满足条件的元素。

  
//list: [a, b, c, d, e]
list.retainWhere((e) => e.compareTo("b") > 0 && e.compareTo("e") < 0);
print(list);

//[c, d]

fillRange

使用fillValue替换[start, end)范围的元素值。

  
//list: [c, d]
list.fillRange(0, 1, "x");
print(list);

//[x, d]

removeWhere

只移除满足条件的元素，与retainWhere相反。

  
//list: [x, d]
list.removeWhere((e) => "x" == e);
print(list);

//[d]

shuffle

随机打乱list元素顺序。

  
//list: ["a", "b", "c", "d", "e"]
list.shuffle();
print(list);

//[d, a, e, c, b]

join

通过连词符将list元素连成字符串。

  
//list: ["a", "b", "c", "d", "e"]
print(list.join(","));

//a,b,c,d,e

where

where与retainWhere不同在于：它不返回真实列表数据，而是满足条件的计算表达式。真正使用时才逐个计算出值。因此它可以多次使用，相互不受影响。

  
//list: ["a", "b", "c", "d", "e"]
var tempList = list.where((e) => e.compareTo("b") > 0 && e.compareTo("e") < 0);
tempList.forEach(print);

//c
//d

skipWhile

依次跳过满足条件的元素，直到遇到第一个不满足的元素x，并停止筛选。返回从x开始的所有元素。跟where返回一样，是一个lazy Iterable。

  
//list: ["a", "b", "c", "d", "e"]
tempList = list.skipWhile((e) => e.compareTo("c") < 0 || e.compareTo("d") > 0);
print(tempList);

//(c, d, e)

takeWhile

依次选择满足条件的元素，直到遇到第一个不满足的元素x，并停止选择。返回从0开始并截止到x前一个元素的所有元素，是一个lazy Iterable。

  
//list: ["a", "b", "c", "d", "e"]
tempList = list.takeWhile((e) => e.compareTo("c") < 0 || e.compareTo("d") > 0);
print(tempList);

//(a, b)

every

列表中所有的元素是否都满足条件。

  
//list: ["a", "b", "c", "d", "e"]
var result = list.every((e) => e.compareTo("a") >= 0);
print(result);

//true

reduce

将列表元素逐个联合。

  
//list: ["a", "b", "c", "d", "e"]
var result2 = list.reduce((e1, e2) => "$e1-$e2");
print(result2);

//a-b-c-d-e

fold

设置头initialValue, 将头与列表元素逐个联合。

  
//list: ["a", "b", "c", "d", "e"]
var result = list.fold("start:", (e1, e2) => "$e1 $e2");
print(result);

//start: a b c d

singleWhere

列表中若只有一个元素满足条件时返回这个值；若有多个会报错；若一个没有返回orElse返回的值；

  
//list: ["a", "b", "c", "d", "e"]
var result3 = list.singleWhere((e) => e.compareTo("e") >= 0, orElse: () => "null");
print(result3);

//e

expand

等价于flatMap。

  
//list: ["a", "b", "c", "d", "e"]
tempList = list.expand((e) => [e, e]);
print(tempList);

//(a, a, b, b, c, c, d, d, e, e)

Stream

Stream的生成

Stream.periodic

周期性发射事件的流。

  
//每3秒发射一次。0,1,4,9,16,25，...
var stream = Stream.periodic(Duration(seconds: 3), (count) => count * count);

Stream.eventTransformed

将当前流转换成Stream<T>（T为任意类型）的流。

  
class MySink implements EventSink<String> {
  EventSink<String> _originalSink;

  MySink(this._originalSink);

  @override
  void add(String event) {
    _originalSink.add(event + event);
  }

  @override
  void addError(Object error, [StackTrace stackTrace]) {
    _originalSink.addError(error, stackTrace);
  }

  @override
  void close() {
    _originalSink.close();
  }
}

//将当前的stream流转成Stream<String>类型的流，且是event -> event + event 的映射逻辑。
Stream.eventTransformed(stream, (EventSink<String> s) => MySink(s));

Stream.fromIterable

发射Iterable元素的流。

  
var stream = Stream.fromIterable(["a", "b", "c", "d"]);

Stream.fromFuture/Stream.fromFutures

接收一个或多个Future, 并等待Future完成后将结果发射出去的流。

Stream.empty

空的流，只会发射done事件。

stream有三种类型的事件：data、done、error。若所有元素都发射完，最后会发射done事件。若出现error, 会发射error事件。

Asynchronous Generator

异步发射器也会生成流。

  
Stream<int> createStream() async* {
  var c = 1;
  while (c <= 5) {
    yield c++;
  }
}

var stream = createStream();

Stream的方法

Stream有很多方法与Iterable类似，可参考Iterable的部分。

listen

监听流的事件，包括data事件、done事件、error事件。

  
var stream = Stream.fromIterable(["a", "b", "c", "d"]);
stream.listen((e) => print("get: $e"), 
              onError: (err) => print("error: $err"), 
              onDone: () => print("done"));

//get: a
//get: b
//get: c
//get: d
//done

transform