котором один из типов эвентов имеет тип Stream<A> и задача на listen'e все эвенты из стрима перенести в контроллер – как быть с закрытием?
Условно:
abstract class Event {}
class Single extends Event {
final int value;
Single(this.value);
}
class Multiple extends Event {
final Stream<Event> events;
Multiple(this.events);
}
final events = StreamController<Event>();
final numbers = StreamController<int>();
final sub = events.stream.listen((event) async {
if (event is Single) numbers.add(event.value);
if (event is Multiple) await events.addStream(event.events);
});
Тут же await в предпоследней строчке – о стену горох. т.е. фактически он же не заэвейтится. Или я не прав и в этом коде все норм?
В целом какойт бред пишешь
Обсуждают сегодня