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