RXJava：如何完成从一个不同的地方观察？

Question

我如何在RxJava中创建一个从不同的地方完成的对象（未来），但我想要向某个客户端返回一个可观察的对象？

class DeferredAction {
    private final CompletableFuture<String> future;
    private final Observable<String> observable;
    public DeferredAction() {
        future = new CompletableFuture<>();
        observable = Observable.from(future);
    }

    public Observable<String> observe() {
        return observable;
    }

    public void complete(Stirng value) {
        future.complete(value);
    }
}

Answer 1

尽管您应该知道publishSubject，它既是可观察的，也是观察者，但这应该起作用，因此您可以这样做：

PublishSubject<String> subject = PublishSubject.create();
subject.take(10).subscribe(sub1);  
subject.last().subscribe(sub2);
subject.onNext("boo");
subject.onCompleted();

正如您所看到的，此模式还支持多个订阅服务器。