เราจะนำคลาส SubmissionPublisher ไปใช้ใน Java 9 ได้อย่างไร

ตั้งแต่ Java 9 เราสามารถสร้าง R สตรีมเชิงโต้ตอบ โดยแนะนำอินเทอร์เฟซหลักสี่ส่วน:ผู้เผยแพร่ , สมาชิก , สมัครสมาชิก , โปรเซสเซอร์ และหนึ่งคลาสที่เป็นรูปธรรม:SubmissionPublisher ที่ใช้ ผู้เผยแพร่ อินเตอร์เฟซ. แต่ละอินเทอร์เฟซมีบทบาทที่แตกต่างกัน ซึ่งสอดคล้องกับหลักการของ ปฏิกิริยา สตรีม . เราสามารถใช้ submit() วิธีการของ Submission Publisher คลาสเพื่อเผยแพร่รายการที่จัดเตรียมให้กับสมาชิกแต่ละคน

ไวยากรณ์

public class SubmissionPublisher<T> extends Object implements Flow.Publisher<T>, AutoCloseable

ในตัวอย่างด้านล่าง เราสามารถใช้ SubmissionPublisher คลาส

ตัวอย่าง

import java.util.concurrent.Flow.Subscriber;
import java.util.concurrent.Flow.Subscription;
import java.util.concurrent.SubmissionPublisher;

class MySubscriber<T> implements Subscriber<T> {
   private Subscription subscription;
   private String name;
   public MySubscriber(String name) {
      this.name = name;
   }
   @Override
   public void onComplete() {
      System.out.println(name + ": onComplete");
   }
   @Override
   public void onError(Throwable t) {
      System.out.println(name + ": onError");
      t.printStackTrace();
   }
   @Override
   public void onNext(T msg) {
      System.out.println(name + ": " + msg.toString() + " received in onNext");
      subscription.request(1);
   }
   @Override
   public void onSubscribe(Subscription subscription) {
      System.out.println(name + ": onSubscribe");
      this.subscription = subscription;
      subscription.request(1);
   }
}

// Main class
public class FlowTest {
   public static void main(String args[]) {
      SubmissionPublisher<String> publisher = new SubmissionPublisher<>();
      MySubscriber<String> subscriber = new MySubscriber<>("Mine");
      MySubscriber<String> subscriberYours = new MySubscriber<>("Yours");
      MySubscriber<String> subscriberHis = new MySubscriber<>("His");
      MySubscriber<String> subscriberHers = new MySubscriber<>("Her");

      publisher.subscribe(subscriber);
      publisher.subscribe(subscriberYours);
      publisher.subscribe(subscriberHis);
      publisher.subscribe(subscriberHers);

      publisher.submit("One");
      publisher.submit("Two");
      publisher.submit("Three");
      publisher.submit("Four");
      publisher.submit("Five");

      try {
         Thread.sleep(1000);
      } catch(InterruptedException e) {
         e.printStackTrace();
      }
      publisher.close();
   }
}

ผลลัพธ์

Yours: onSubscribe
His: onSubscribe
Mine: onSubscribe
His: One received in onNext
Yours: One received in onNext
Mine: One received in onNext
Yours: Two received in onNext
His: Two received in onNext
Yours: Three received in onNext
Mine: Two received in onNext
Yours: Four received in onNext
His: Three received in onNext
Yours: Five received in onNext
Mine: Three received in onNext
Her: onSubscribe
His: Four received in onNext
Her: One received in onNext
Mine: Four received in onNext
Her: Two received in onNext
His: Five received in onNext
Her: Three received in onNext
Mine: Five received in onNext
Her: Four received in onNext
Her: Five received in onNext
Yours: onComplete
His: onComplete
Mine: onComplete
Her: onComplete