TestSubject in RxJava

Question

我正在研究一个由Netflix开发的名为RxJava的反应性扩展的java实现。

似乎他们已经选择将.NET Subject<T>实现为TestSubject<T>。有人知道为什么它叫TestSubject<T>，我认为它可能不该被使用吗？

我看不出如何从类中的方法中创建一个可观察的方法。例如。

public class MyClass extends MyBase {

    @Override
    public void onText(String text) {
        // TODO: push onto some observable here - do I use a TestSubject?
    }
}

Answer 1

Java中的等效类称为PublishSubject<T>，因为Subject是抽象的基础。