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>

Beispiel

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");
         }
      });
   }
}

Ausgabe

<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!