Skip to content

Instantly share code, notes, and snippets.

View RationalEgoism's full-sized avatar
👀

Stanislav Talanov RationalEgoism

👀
View GitHub Profile
@RationalEgoism
RationalEgoism / broadcastStream.dart
Created January 27, 2022 11:44
Broadcast stream with transformer
void main() {
var streamController = StreamController<int>.broadcast();
streamController.stream
.where((event) => event % 2 == 0)
.listen((event) => print('First sub for odd number: $event'));
streamController.stream
.map((event) => event * event)
.listen((event) => print('Second sub square number: $event'));
@RationalEgoism
RationalEgoism / singleSubscription.dart
Last active January 27, 2022 11:47
“Single-subscription” Dart Stream
void main() {
var streamController = StreamController();
streamController.stream.listen((event) {
print(event);
});
// Runtime error Bad state: Stream has already been listened to.
// streamController.stream.listen((event) {
// print('Second subscription: $event');
// });
streamController.sink.add('dddd');