জাভা ৯ থেকে আমরা রিয়েক্টিভ স্ট্রিম তৈরি করতে পারি চারটি কোর ইন্টারফেস প্রবর্তন করে: Publisher, Subscriber, Subscription, Processor, এবং একটি কনক্রিট ক্লাস: SubmissionPublisher যা Publisher ইন্টারফেস ইমপ্লিমেন্ট করে। প্রতিটি ইন্টারফেস আলাদা ভূমিকা পালন করে, রিয়েক্টিভ স্ট্রিম-এর প্রিন্সিপল অনুযায়ী। আমরা SubmissionPublisher ক্লাসের submit() মেথড ব্যবহার করে প্রদত্ত আইটেম প্রতিটি সাবস্ক্রাইবারের কাছে পাবলিশ করতে পারি।
সিনট্যাক্স
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: onComplete His: onComplete Mine: onComplete Her: onComplete
