Wie implementiert man die Flow.Publisher-Schnittstelle in Java 9?
Eine Publisher-Schnittstelle ist ein Anbieter, der eine unbegrenzte Anzahl bestellter Elemente zur Veröffentlichung bereitstellt, basierend auf der Nachfrage seiner Abonnenten. Mögliche Aufrufsequenz von Methoden auf Publisher.subscribe(Subscriber) als Reaktion auf den Aufruf von Subscriber. Dies bedeutet die onSubscribe()-Methode, gefolgt von einer unbegrenzten Anzahl von onNext()-Methoden (wie vom Subscriber benötigt), dann entweder die onError()-Methode (falls ein Fehler auftritt) oder die onComplete()-Methode (wenn keine weiteren Elemente verfügbar sind, solange Abonnement nicht gekündigt wurde).
Syntax<strong>public interface Publisher<T> {
public void subscribe(Subscriber<? super T><!--? super T--> s);
}</strong>
Nach dem Login kopieren
Beispiel<strong>public interface Publisher<T> { public void subscribe(Subscriber<? super T><!--? super T--> s); }</strong>
import java.util.concurrent.*;
import java.util.*;
import java.util.stream.*;
class SimplePublisher implements <strong>Flow.Publisher<Integer></strong> {
private final <strong>Iterator<Integer></strong> iterator;
SimplePublisher(int count) {
this.iterator = <strong>IntStream</strong>.rangeClosed(1, count).iterator();
}
<strong>@Override</strong>
public void <strong>subscribe</strong>(<strong>F</strong><strong>low.Subscriber<? super Integer></strong><!--? super Integer--> subscriber) {
iterator.<strong>forEachRemaining</strong>(<strong>subscriber::onNext</strong>);
subscriber.<strong>onComplete()</strong>;
}
}
public class SimplePublisherImplTest {
public static void main(String args[]) {
new SimplePublisher(10).<strong>subscribe</strong>(new <strong>Flow.Subscriber<>()</strong> {
<strong>@Override</strong>
public void <strong>onSubscribe</strong>(<strong>Flow.Subscription</strong> subscription) {
}
<strong>@Override</strong>
public void <strong>onNext</strong>(Integer item) {
System.out.println("item = [" + item + "]");
}
<strong>@Override</strong>
public void <strong>onError</strong>(Throwable throwable) {
}
<strong>@Override</strong>
public void <strong>onComplete()</strong> {
System.out.println("complete");
}
});
}
}
Nach dem Login kopieren
Ausgabeimport java.util.concurrent.*; import java.util.*; import java.util.stream.*; class SimplePublisher implements <strong>Flow.Publisher<Integer></strong> { private final <strong>Iterator<Integer></strong> iterator; SimplePublisher(int count) { this.iterator = <strong>IntStream</strong>.rangeClosed(1, count).iterator(); } <strong>@Override</strong> public void <strong>subscribe</strong>(<strong>F</strong><strong>low.Subscriber<? super Integer></strong><!--? super Integer--> subscriber) { iterator.<strong>forEachRemaining</strong>(<strong>subscriber::onNext</strong>); subscriber.<strong>onComplete()</strong>; } } public class SimplePublisherImplTest { public static void main(String args[]) { new SimplePublisher(10).<strong>subscribe</strong>(new <strong>Flow.Subscriber<>()</strong> { <strong>@Override</strong> public void <strong>onSubscribe</strong>(<strong>Flow.Subscription</strong> subscription) { } <strong>@Override</strong> public void <strong>onNext</strong>(Integer item) { System.out.println("item = [" + item + "]"); } <strong>@Override</strong> public void <strong>onError</strong>(Throwable throwable) { } <strong>@Override</strong> public void <strong>onComplete()</strong> { System.out.println("complete"); } }); } }
<strong>item = [1]
item = [2]
item = [3]
item = [4]
item = [5]
item = [6]
item = [7]
item = [8]
item = [9]
item = [10]
complete</strong>
Nach dem Login kopieren
<strong>item = [1] item = [2] item = [3] item = [4] item = [5] item = [6] item = [7] item = [8] item = [9] item = [10] complete</strong>
Das obige ist der detaillierte Inhalt vonWie implementiert man die Flow.Publisher-Schnittstelle in Java 9?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Heiße KI -Werkzeuge

Undresser.AI Undress
KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover
Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool
Ausziehbilder kostenlos

Clothoff.io
KI-Kleiderentferner

AI Hentai Generator
Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

Heiße Werkzeuge

Notepad++7.3.1
Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version
Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1
Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6
Visuelle Webentwicklungstools

SublimeText3 Mac-Version
Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Heiße Themen

Dieser Artikel analysiert 2025 die vier besten JavaScript -Frameworks (React, Angular, Vue, Svelte) und verglichen ihre Leistung, Skalierbarkeit und Zukunftsaussichten. Während alle aufgrund starker Gemeinschaften und Ökosysteme dominant bleiben, sind ihr relatives Popul

In dem Artikel wird in der Implementierung von mehrstufigem Caching in Java mithilfe von Koffein- und Guava-Cache zur Verbesserung der Anwendungsleistung erläutert. Es deckt die Einrichtungs-, Integrations- und Leistungsvorteile sowie die Bestrafung des Konfigurations- und Räumungsrichtlinienmanagements ab

Node.js 20 verbessert die Leistung durch V8 -Motorverbesserungen erheblich, insbesondere durch schnellere Müllsammlung und E/A. Zu den neuen Funktionen gehören eine bessere Support von WebAssembly und raffinierte Debugging -Tools, die Produktivität der Entwickler und die Anwendungsgeschwindigkeit.

Mit der Klassenbelastung von Java wird das Laden, Verknüpfen und Initialisieren von Klassen mithilfe eines hierarchischen Systems mit Bootstrap-, Erweiterungs- und Anwendungsklassenloadern umfasst. Das übergeordnete Delegationsmodell stellt sicher

Iceberg, ein offenes Tabellenformat für große analytische Datensätze, verbessert die Leistung und Skalierbarkeit von Data Lake. Es befasst sich mit Einschränkungen von Parquet/ORC durch internes Metadatenmanagement und ermöglicht eine effiziente Schemaentwicklung, Zeitreisen, gleichzeitiger W

Dieser Artikel befasst sich mit der Verwundbarkeit von CVE-2022-1471 in Snakeyaml, einem kritischen Fehler, der die Ausführung von Remote-Code ermöglicht. Es wird beschrieben

In diesem Artikel wird die Integration der funktionalen Programmierung in Java unter Verwendung von Lambda -Ausdrücken, Streams -API, Methodenreferenzen und optional untersucht. Es zeigt Vorteile wie eine verbesserte Lesbarkeit der Code und die Wartbarkeit durch SUKTIVE UND VERUSNAHMETALITÄT

In dem Artikel werden Maven und Gradle für Java -Projektmanagement, Aufbau von Automatisierung und Abhängigkeitslösung erörtert, die ihre Ansätze und Optimierungsstrategien vergleichen.
