Rxjava 简明教程
RxJava - AsyncSubject
AsyncSubject 仅发出最后的值，然后向观察者发出完成事件或接收到的错误。
Class Declaration
io.reactivex.subjects.AsyncSubject<T> 类的声明如下：
public final class AsyncSubject<T>
extends Subject<T>AsyncSubject Example
在任意编辑器中使用任何您选择的语言（如 C:\>RxJava) 创建以下 Java 程序。
ObservableTester.java
import io.reactivex.subjects. AsyncSubject;
public class ObservableTester {
public static void main(String[] args) {
final StringBuilder result1 = new StringBuilder();
final StringBuilder result2 = new StringBuilder();
AsyncSubject<String> subject = AsyncSubject.create();
subject.subscribe(value -> result1.append(value) );
subject.onNext("a");
subject.onNext("b");
subject.onNext("c");
subject.subscribe(value -> result2.append(value));
subject.onNext("d");
subject.onComplete();
//Output will be d being the last item emitted
System.out.println(result1);
//Output will be d being the last item emitted
System.out.println(result2);
}
}