stream = widget.store.onChange
.where(_ignoreChange)
.map(_mapConverter)
// Don't use Stream.distinct
because it cannot capture the initial
// ViewModel produced by the converter
.
.where(_whereDistinct)
// After each ViewModel is emitted from the Stream, we update the
// latestValue. Important: This must be done after all other optional
// transformations, such as ignoreChange.
.transform(StreamTransformer.fromHandlers(handleData: _handleChange));
О, увидел, у стора есть стрим изменения состояния, на который можно подписываться, минуя коннектор, вы это имели в виду? Это как-раз похоже на одно из решений моей проблемы