Bagaimana untuk melaksanakan antara muka Flow.Publisher dalam Java 9?

A Penerbit antara muka ialah penyedia yang menyediakan bilangan unsur tertib yang tidak terhad untuk diterbitkan berdasarkan permintaan yang diterima daripada Pelanggannya. Urutan kaedah panggilan yang mungkin pada Publisher.subscribe(Subscriber), sebagai respons kepada panggilan Subscriber. Ini bermakna kaedah onSubscribe(), diikuti dengan kaedah onNext() tanpa had (seperti yang dikehendaki oleh Subscriber), kemudian sama ada kaedah onError() (jika terdapat kegagalan) atau Kaedah onComplete() ( apabila tiada lagi elemen tersedia, selagi Langganan belum dibatalkan).

Syntax

<strong>public interface Publisher<T> {
   public void subscribe(Subscriber<? super T><!--? super T--> s);
}</strong>

Contoh

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

Output

<strong>item = [1]
item = [2]
item = [3]
item = [4]
item = [5]
item = [6]
item = [7]
item = [8]
item = [9]
item = [10]
complete</strong>

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan antara muka Flow.Publisher dalam Java 9?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!