Java 9 প্রতিক্রিয়াশীল স্ট্রীম চালু করেছে java.util.concurrent.Flow এর অধীনে প্যাকেজ যা একটি ইন্টারঅপারেবল প্রকাশ-সাবস্ক্রাইব সমর্থন করে কাঠামো এটি অ্যাসিঙ্ক্রোনাস সীমানা জুড়ে ডেটার একটি অ্যাসিঙ্ক্রোনাস স্ট্রীম প্রক্রিয়া করে (অন্য থ্রেড বা থ্রেড-পুলে উপাদানগুলি পাস করা), এবং গ্রহণকারী পক্ষকে ইচ্ছামত পরিমাণে ডেটা বাফার করতে বাধ্য করা হয় না, তারপরে বাফার ওভারফ্লো ঘটতে পারে না৷
ফ্লো API৷ চারটি আন্তঃসম্পর্কিত মূল ইন্টারফেস রয়েছে:প্রকাশক , সাবস্ক্রাইবার , সদস্যতা , এবং প্রসেসর .
সিনট্যাক্স
@FunctionalInterface
public static interface Publisher<T> {
public void subscribe(Subscriber<? super T> subscriber)
}
public static interface Subscriber<T> {
public void onSubscribe(Subscription subscription);
public void onNext(T item);
public void onError(Throwable throwable);
public void onComplete();
}
public static interface Subscription {
public void request(long n);
public void cancel();
}
public static interface Processor<T, R> extends Subscriber<T>, Publisher<R> {
} এই চারটি ইন্টারফেস:প্রবাহ। প্রকাশক , ফ্লো।প্রসেসো r, Flow.Subscriber, এবংপ্রবাহ। সদস্যতা প্রতিক্রিয়াশীল স্ট্রিম স্পেসিফিকেশন সম্পর্কিত। প্রকাশক ইন্টারফেসে subscribe() আছে পদ্ধতি, সাবস্ক্রিপশন আছে বাতিল() এবং অনুরোধ() পদ্ধতি এবং সাবস্ক্রাইবার onSubscribe() আছে , পরবর্তী() , onError() , এবং onComplete() পদ্ধতি প্রসেসর ইন্টারফেস প্রবাহের সমস্ত পদ্ধতি প্রয়োগ করে। প্রকাশক এবং Flow.Subscriber ইন্টারফেস।
