Связь Repository с UseCase Forge

Binding принадлежит Application-слою, потому что именно он решает, какое изменение данных становится каким Command.

final class CatalogBinding {
  CatalogBinding(CatalogRepository repository, CatalogUseCase useCase)
    : _subscription = repository.stream.listen(
        (data) => useCase.add(CatalogChanged(data)),
      );

  final StreamSubscription<CatalogData> _subscription;
  Future<void> close() => _subscription.cancel();
}

Прямая подписка обрабатывает replay текущего значения. Используйте stream.skip(1), если Command должны создаваться только для будущих commit.

Слушатель не выполняет асинхронную бизнес-логику. Admission, debounce, throttle, группировка Execution, отмена, ошибки и диагностика остаются в UseCase Forge.