к примеру метод репозитория может быть генератором
А как вот с таким репозиторием правильно работать? это же получается надо делать подписку, а потом отписываться когда уже не нужно будет. А что если ты подписался один раз, а потом в стриме случилась ошибка и он сдох. Или делать как в блоке глушить все ошибки?