Bagaimana untuk melaksanakan penstriman reaktif menggunakan Flow API dalam Java 9?

Flow API ialah sokongan rasmi untuk spesifikasi aliran reaktif sejak Java 9. Ia adalah gabungan corak Iterator dan Pemerhati . Flow API ialah spesifikasi interop, bukan API pengguna akhir seperti RxJava.

Flow API terdiri daripada empat antara muka asas:

• Pelanggan: Pelanggan melanggan panggilan balik kepada penerbit.
• Penerbit: Penerbit menerbitkan aliran item data kepada pelanggan berdaftar.
• Langganan: Pautan antara penerbit dan pelanggan.
• Pemproses: Pemproses terletak di antara penerbit dan pelanggan dan menukar satu strim kepada yang lain.

Dalam contoh di bawah, kami mencipta pelanggan asas yang meminta objek data, mencetaknya dan meminta objek data lain. Kami boleh menggunakan pelaksanaan penerbit yang disediakan oleh Java (SubmissionPublisher) untuk melengkapkan sesi kami.

Contoh

import java.util.concurrent.Flow;
import java.util.List;
import java.util.concurrent.SubmissionPublisher;

class MySubscriber<T>implements <strong>Flow.Subscriber<T></strong> {
   private <strong>Flow.Subscription</strong> subscription;
   <strong>@Override</strong>
   public void <strong>onSubscribe</strong>(Flow.Subscription subscription) {
      this.subscription = subscription;
      this.subscription.request(1);
   }
   <strong>@Override</strong>
   public void <strong>onNext</strong>(T item) {
      System.out.println(item);
      subscription.request(1);
   }
   <strong>@Override</strong>
   public void <strong>onError</strong>(Throwable throwable) {
      throwable.printStackTrace();
   }
   <strong>@Override</strong>
   public void <strong>onComplete</strong>() {
      System.out.println("Done");
   }
}

<strong>// main class</strong>
public class FlowTest {
   public static void main(String args[]) {
      <strong>List<String></strong> items = <strong>List.of</strong>("1", "2", "3", "4", "5", "6", "7", "8", "9", "10");
      <strong>SubmissionPublisher<String></strong> publisher = new SubmissionPublisher<>();
      publisher.<strong>subscribe</strong>(new MySubscriber<>());
      items.forEach(s -> {
         try {
            Thread.sleep(1000);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
         publisher.<strong>submit</strong>(s);
      });
      publisher.close();
   }
}

Output

<strong>1
2
3
4
5
6
7
8
9</strong>
<strong>10
Done</strong>

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