0

假设我有一个Person接口，它有一个name可观察的：

interface Person {
  Observable<String> name;
}

它的实现：

class David implements Person {
  Observable<String> name = BehaviorSubject<>.createDefault("David");
}

现在有一个问题，因为我无法获得name可观察的当前值：

class Main {
  public static void main(String[] args) {
    Person person = PersonFactory.create();
    System.out.println(??person.name.currentValue??);
  }
}

我不想在我的界面中将名称公开为 BehaviorSubject，因为这样每个人都可以更改名称，这不是我想要的。

我有点理解 Observables 的逻辑，所以我知道它们不是为了存储任何值而设计的。那么什么是 RxJava 中的“具有当前值的不可变可观察对象”？

在 Android 中有一个LiveData和MutableLiveData。我的理解MutableLiveData是等价于BehaviorSubject，那么LiveData在 RxJava 中的等价物是什么？

4

2 回答 2

1

将变量的类型定义name为内部的主题，David并使用该hide()方法公开为可观察的。使用 hide 将确保外部世界无法调用onNext，即改变名称。在此处查看 hide() 的文档

class David implements Person {
  
    private PublishSubject<String> nameSubject = BehaviorSubject<>.createDefault("David");

    public Observable<String> observeName() {
        return nameSubject.hide();
    }

    // If you want the outside world to update the name
    public void setName(String name) {
        nameSubject.onNext(name)
    }
}
于 2020-10-18T01:50:16.347 回答
0

我决定LiveData使用现场委托创建自己的

interface LiveData<out T> {
    val observable: Observable<out T>
    val value: T

    fun subscribe(onNext: Consumer<in T>): Disposable = observable.subscribe(onNext)
}

class MutableLiveData<T>(initial: T) : LiveData<T> {
    private val subject: BehaviorSubject<T> = BehaviorSubject.createDefault(initial)

    override val observable: Observable<out T> = subject

    override var value: T
        get() = subject.value
        set(value) = subject.onNext(value)

    fun mutate(mutationFunction: T.() -> Unit) {
        value.mutationFunction()
        value = value
    }
}
于 2020-10-19T06:04:03.283 回答