stream_taker 1.0.0 copy "stream_taker: ^1.0.0" to clipboard
stream_taker: ^1.0.0 copied to clipboard

stream.take multi times,

stream_taker #

dart Stream.take分多次取数据,

Features #

针对Stream.take无法分多次取数据的问题,单独封装一个类确保只listen一次,take几个就只消费几个,

Getting started #

dart pub add stream_taker

Usage #

stream_taker_test.dart

    streamSplit = StreamTaker(createStream(5));
    list = await streamSplit.take(1).toList();
    expect([0], list);
    await Future.delayed(Duration(seconds: 1));
    list = await streamSplit.take(2).toList();
    expect([1, 2], list);
    await Future.delayed(Duration(seconds: 1));
    list = await streamSplit.take(3).toList();
    // 只剩两个,就只得到两个,
    expect([3, 4], list);
1
likes
120
points
15
downloads

Publisher

unverified uploader

Weekly Downloads

stream.take multi times,

Repository (GitHub)
View/report issues

Documentation

API reference

License

MIT (license)

More

Packages that depend on stream_taker