Skip to content

Instantly share code, notes, and snippets.

@AlexKenbo
Created March 9, 2020 16:59
Show Gist options
  • Save AlexKenbo/37b3605c170bdfeb13e29614ebe6ac87 to your computer and use it in GitHub Desktop.
Save AlexKenbo/37b3605c170bdfeb13e29614ebe6ac87 to your computer and use it in GitHub Desktop.
Stream take
// asynchronous data
main() async {
Duration interval = Duration(seconds: 1);
Stream<int> stream = Stream<int>.periodic(interval,transform);
// Added this statement
stream = stream.take(5);
await for(int i in stream){
print(i);
}
}
int transform(int x){
return (x + 1) * 2;
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment