Event handling in flutter?

Question

Dart

Good afternoon! Help with advice, I use RxDart and BLoC.
In bloc, my data is processed in a loop and events are sent in it:

final _controller = BehaviorSubject();

for(var item in items){
var data = [];

/* тут код */

_controller.add(State._status(SearchStatus.inProgress));
_controller.add(State._data(data));
}

but for some reason only the last event always comes to the StreamBuilder ... I thought that I needed to specify another subscription class pub.dev/documentation/rxdart/latest/rx_subjects/rx_subjects-library.html but it didn’t help.

How to be?

Thank you!

Answer 1

The docs say: A special StreamController that captures the latest item that has been added to the controller , and emits that as the first item to any new listener.
Use ReplaySubject instead of BehaviorSubject