Ich lerne die Reaktiv-Stream-API von Java 9.Wie übertrage ich eine Nachricht an einen anderen Abonnenten?
Wie hat es die Verleger und Abonnenten, und der Abonnent abonniert dem Verleger und der Abonnent implementiert auch die folgenden Meldungen:
public class TestSubscriber<T> implements Subscriber<T> {
@Override
public void onComplete() {
// TODO Auto-generated method stub
}
@Override
public void onError(Throwable arg0) {
// TODO Auto-generated method stub
}
@Override
public void onNext(T arg0) {
// TODO Auto-generated method stub
}
@Override
public void onSubscribe(Subscription arg0) {
// TODO Auto-generated method stub
}
}
Ich habe Keine Methode im Subscriber gefunden, die die Nachricht an einen anderen Teilnehmer weiterleitet/überträgt. Irgendwelche Vorschläge?
Interessant, aber was soll das für erforderlich? Ich meine, wenn wir über ein [Abonnement] sprechen (https://docs.oracle.com/javase/9/docs/api/java/util/concurrent/Flow.Subscription.html), ist es zwischen einem Abonnenten und einem Herausgeber im Allgemeinen. – nullpointer
Sagen Sie, wenn ein Abonnent die Nachricht ändern/ändern und an einen anderen Abonnenten übergeben möchte – KayV
Erstens, ich denke, Sie können diese https://stackoverflow.com/questions/47936868/can-a-subscriber-act-as-a zusammenführen -publisher und behalte eins mit der detaillierten Frage. – nullpointer