উদাহরণ: RxJava, ReactiveX

Reactive Programming - প্রোগ্রামিং মেথডলোজি (Programming Methodologies) - Computer Science

306

 

RxJava এবং ReactiveX হল রিঅ্যাক্টিভ প্রোগ্রামিংয়ের জন্য ব্যবহৃত দুটি জনপ্রিয় লাইব্রেরি। তারা ডেটা স্ট্রিম এবং অ্যাসিনক্রোনাস প্রোগ্রামিংয়ের উপর ভিত্তি করে কাজ করে এবং একটি কার্যকরী পদ্ধতিতে ইভেন্টগুলি পরিচালনা করতে সহায়ক।

১. RxJava

RxJava হল Java-এ Reactive Programming-এর জন্য একটি লাইব্রেরি। এটি ডেটা স্ট্রিম এবং ইভেন্টগুলির উপর ভিত্তি করে অ্যাসিনক্রোনাস প্রোগ্রামিং পরিচালনার জন্য একটি শক্তিশালী টুল।

বৈশিষ্ট্য

  • Observable: ডেটা স্ট্রিম বা ইভেন্টগুলির উত্স।
  • Observer: Observable থেকে তথ্য পাওয়া অবজেক্ট।
  • Operators: ডেটা স্ট্রিমের পরিবর্তন বা পরিচালনার জন্য বিভিন্ন ফাংশন।

উদাহরণ

import io.reactivex.rxjava3.core.Observable;

public class RxJavaExample {
    public static void main(String[] args) {
        // Observable তৈরি
        Observable<String> observable = Observable.just("Hello", "World");

        // Observer তৈরি এবং Observable-এ সংযুক্ত
        observable.subscribe(
            item -> System.out.println("Received: " + item),
            Throwable::printStackTrace,
            () -> System.out.println("Done")
        );
    }
}

Output:

Received: Hello
Received: World
Done

২. ReactiveX

ReactiveX হল একটি রিঅ্যাক্টিভ প্রোগ্রামিং এপিআই যা বিভিন্ন প্রোগ্রামিং ভাষায় উপলব্ধ। এটি RxJava সহ অন্যান্য ভাষার জন্য বিভিন্ন সংস্করণে কাজ করে, যেমন RxJS (JavaScript), RxSwift (Swift), RxKotlin (Kotlin) ইত্যাদি।

বৈশিষ্ট্য

  • Cross-Language Support: বিভিন্ন ভাষায় উপলব্ধ, যা একাধিক প্ল্যাটফর্মে রিঅ্যাক্টিভ প্রোগ্রামিংয়ের জন্য সুবিধাজনক।
  • Composability: একাধিক অপারেটরের মাধ্যমে ডেটা স্ট্রিমগুলিকে একত্রিত করা যায়।
  • Easy Error Handling: ত্রুটি পরিচালনার জন্য সহজ পদ্ধতি প্রদান করে।

উদাহরণ (RxJS - JavaScript)

// RxJS উদাহরণ
const { of } = require('rxjs');
const { map } = require('rxjs/operators');

// Observable তৈরি
const numbers = of(1, 2, 3, 4, 5);

// অপারেটর ব্যবহার
const squaredNumbers = numbers.pipe(
    map(num => num * num)
);

// Subscriber তৈরি
squaredNumbers.subscribe(
    value => console.log(value) // Output: 1, 4, 9, 16, 25
);

উপসংহার

RxJava এবং ReactiveX হল রিঅ্যাক্টিভ প্রোগ্রামিংয়ের জন্য অত্যন্ত কার্যকরী টুল। তারা ডেটা স্ট্রিম এবং ইভেন্টগুলির পরিচালনার জন্য একটি সহজ এবং কার্যকরী পদ্ধতি প্রদান করে, যা ডেভেলপারদের জন্য উন্নত ইউজার অভিজ্ঞতা নিশ্চিত করে। এই লাইব্রেরিগুলি বিভিন্ন ভাষায় উপলব্ধ, যা রিঅ্যাক্টিভ ডিজাইনের বিভিন্ন প্ল্যাটফর্মে ব্যবহার করা সম্ভব করে

Content added By
Promotion

Are you sure to start over?

Loading...