При использовании RxJava обновления подписчику не приходят

Я только начал изучать RxJava и столкнулся с проблемой.

У меня есть метод который делает запрос в Firebase Storage и при удачном исходе возвращает Observable(Uri)

public Observable<Uri> get() {
        final PublishSubject<Uri> subject = PublishSubject.create();
        Variables.storageReference.child("images/" + id).getDownloadUrl()
                .addOnSuccessListener(
                        uri -> subject.onNext(uri)
                );
        return subject;
    }

Другой метод получает этот Observable и что-то дальше выполняет.

get()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
                        uri -> {
                            // ...
                        }
                );

Позже я добавляю файл в Firebase Storage и по логике это должно выполниться ещё раз (т.к. я подписался на обновления). Но Это срабатывает один раз и всё. Может я просто что-то не допонимаю до конца


Ответы (0 шт):