Как дополнить библиотеку RxJs функцией update() для запуска next()?

Я не нашёл возможности в RxJs изменить BehaviorSubject только если значение изменено.
(да, конечно мы можем в подписке написать DistinctUntilChanged), но я о первоначальном добавлениии в стрим.
Я хочу, что б сперва проверялось .getValue() и если оно отличается, то выполнить next()
Как такое сделать?
Это с прототипом или декоратором или ещё как-то ?