RxJS-এ Observable তৈরি করা এবং তা subscribe করা একটি গুরুত্বপূর্ণ প্রক্রিয়া, যার মাধ্যমে আপনি অ্যাসিঙ্ক্রোনাস ডেটা বা ইভেন্ট স্ট্রিমের ওপর কাজ করতে পারেন। এখানে আমরা ধাপে ধাপে দেখব কিভাবে একটি Observable তৈরি করতে হয় এবং তার পর কীভাবে সাবস্ক্রাইব করে ডেটা বা ইভেন্ট গ্রহণ করা হয়।
Observable তৈরি করা
RxJS-এ Observable এমন একটি সিকোয়েন্স বা স্ট্রিমের প্রতিনিধিত্ব করে যা একাধিক মান (values) সময়ের সাথে সাথে তৈরি করতে পারে। একটি Observable তৈরির জন্য new Observable() কন্সট্রাক্টর ব্যবহার করা হয়।
উদাহরণ:
import { Observable } from 'rxjs';
const observable = new Observable(subscriber => {
subscriber.next(1); // প্রথম মান
subscriber.next(2); // দ্বিতীয় মান
subscriber.next(3); // তৃতীয় মান
subscriber.complete(); // Observable শেষ
});
এখানে, subscriber একটি অবজার্ভার (Observer) হিসেবে কাজ করে এবং তার মাধ্যমে আপনি ডেটার মানগুলো পাঠান। next() ফাংশন দ্বারা ডেটা পাঠানো হয় এবং complete() ফাংশন দ্বারা Observable শেষ ঘোষণা করা হয়।
Observable এর সাথে Subscribe করা
একবার একটি Observable তৈরি করার পর, সেই Observable থেকে ডেটা বা ইভেন্ট গ্রহণ করতে আপনাকে subscribe করতে হবে। subscribe() মেথড ব্যবহার করে আপনি Observable-এ সাবস্ক্রাইব করেন এবং এটি একটি Observer কে পাস করে, যা Observable থেকে ডেটা গ্রহণ করবে।
উদাহরণ:
observable.subscribe({
next(x) { console.log(x); }, // ডেটা প্রাপ্তির পর
complete() { console.log('Complete!'); } // Observable শেষ হলে
});
এখানে next() ফাংশনটি প্রতি নতুন মান পাওয়ার পর কল হয় এবং complete() ফাংশনটি Observable শেষ হওয়ার পরে কল হয়।
Observable এর সাথে Error Handling
RxJS-এ error হ্যান্ডলিংও অত্যন্ত গুরুত্বপূর্ণ। যদি কোনো ভুল ঘটে, তাহলে আপনি error() মেথড ব্যবহার করতে পারেন। এটি আপনাকে কোনো ধরনের ভুলের ক্ষেত্রে সঠিকভাবে প্রতিক্রিয়া জানাতে সাহায্য করবে।
উদাহরণ:
const observableWithError = new Observable(subscriber => {
subscriber.next(1);
subscriber.next(2);
subscriber.error('Something went wrong!');
});
observableWithError.subscribe({
next(x) { console.log(x); },
error(err) { console.log('Error: ' + err); }, // Error হ্যান্ডলিং
complete() { console.log('Complete!'); }
});
এখানে, error() মেথডটি ডাকা হয়েছে এবং এর মাধ্যমে আপনি যেকোনো ত্রুটি বা ভুল মোকাবেলা করতে পারেন।
সারাংশ
RxJS-এ Observable তৈরি এবং তার সাথে subscribe করা একটি মূল উপাদান, যা অ্যাসিঙ্ক্রোনাস ডেটা বা ইভেন্টগুলির সাথে কাজ করার জন্য ব্যবহৃত হয়। new Observable() দিয়ে একটি Observable তৈরি করা হয় এবং subscribe() মেথড ব্যবহার করে আপনি সেই Observable থেকে ডেটা গ্রহণ করেন। এছাড়াও, আপনি error এবং complete মেথড ব্যবহার করে ভুল এবং শেষ অবস্থা নিয়ন্ত্রণ করতে পারেন।
Read more
