A প্রকাশক ৷ সীমাহীন সংখ্যক অনুক্রমিক উপাদানের একটি প্রদানকারী যা তাদের গ্রাহকদের কাছ থেকে প্রাপ্ত চাহিদা অনুযায়ী প্রকাশ করে। প্রকাশক
public interface Publisher<T> {
public void subscribe(Subscriber<? super T> s);
} প্রকাশক ইন্টারফেসের জন্য নিয়ম:
- মোট সংখ্যা onNext() প্রকাশক দ্বারা সংকেত পদ্ধতি একজন সাবস্ক্রাইবার কে গ্রাহকের সাবস্ক্রিপশন দ্বারা অনুরোধ করা উপাদানগুলির মোট সংখ্যার কম বা সমান হতে হবে সব সময়ে।
- একজন প্রকাশক পরবর্তী() কম সংকেত দিতে পারে অনুরোধের চেয়ে পদ্ধতি, এবং সাবস্ক্রিপশন বন্ধ করুন onComplete() কল করে অথবা onError() পদ্ধতি।
- অনসাবস্ক্রাইব() , পরবর্তী() , onError() , এবং onComplete() পদ্ধতিগুলি একজন সাবস্ক্রাইবারকে নির্দেশ করে৷ ক্রমিকভাবে সংকেত দিতে হবে।
- যদি প্রকাশক ব্যর্থ হয়, তাহলে এটি অবশ্যই একটি অন-ইরর() সংকেত দেবে পদ্ধতি।
- যদি প্রকাশক সফলভাবে সমাপ্ত হয়, তাহলে এটি অবশ্যই একটি অনকমপ্লিট() সংকেত দেবে পদ্ধতি।
- যদি প্রকাশক হয় onError() সংকেত দেয় অথবা oncomplete() সাবস্ক্রাইবার-এ পদ্ধতি , তাহলে গ্রাহকের সদস্যতা অবশ্যই বাতিল করতে হবে।
- একবার টার্মিনাল স্টেট সিগন্যাল হয়ে গেলে (onError() , oncomplete() ), এটি প্রয়োজন যে আর কোন সংকেত ঘটতে পারে না।
- সাবস্ক্রিপশন বাতিল করা হলে, এর গ্রাহককে অবশ্যই সংকেত দেওয়া বন্ধ করতে হবে।
- Publisher.subscribe()৷ পদ্ধতিকে অবশ্যই কল করতে হবে onSubscribe() সাবস্ক্রাইবার কে অন্য কোনো সংকেত দেওয়ার আগে প্রদত্ত গ্রাহকের উপর পদ্ধতি এবং সাধারণত প্রত্যাবর্তন করে, ব্যতীত যখন প্রদত্ত গ্রাহক শূন্য থাকে৷ এই ক্ষেত্রে, এটি অবশ্যই একটি NullPointerException নিক্ষেপ করবে৷ কলকারীর কাছে।
- Publisher.subscribe()৷ পদ্ধতি প্রতিবার আলাদা গ্রাহকের সাথে যতবার প্রয়োজন ততবার কল করতে পারে।
- একজন প্রকাশক একাধিক সদস্যকে সমর্থন করতে পারে এবং প্রতিটি সদস্যতা ইউনিকাস্ট হতে পারে কিনা তা নির্ধারণ করে অথবা মাল্টিকাস্ট .
