Wie erstelle ich in RxJava ein Objekt (Zukunft), das von einem anderen Ort aus abgeschlossen wird, aber ich möchte ein Observable an einen Kunden zurückgeben?RxJava: Wie kann man von einem anderen Ort aus beobachtbar gemacht werden?
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);
}
}
Ist das der richtige Weg? Zweite Frage: Wie kann ich mehrere Abonnenten auf diese Observable bekommen? Im Moment sehe ich, dass nur ein Abonnent arbeitet.