Angular | RxJS

خلينا نبص على RxJS بطريقة أقرب للواقع 👇 تخيل إن عندك "حنفية بيانات" مفتوحة المياه (data) بتنزل مع الوقت… مش مرة واحدة ده بالظبط هو الـ Observable مصدر بيبعت values over time وانت بتعمل subscribe عشان تستقبل كل value أول ما توصل طيب… المشكلة مش في وصول البيانات المشكلة: هتتعامل معاها إزاي؟ هنا بييجي دور pipe & Operators تخيل إن عندك خط إنتاج: البيانات داخلة - بتتفلتر - تتعدل -تتظبط - وبعدين توصل لك وده بيحصل عن طريق pipe اللي بتركب جواه Operators ورا بعض: map يغير شكل الداتا filter يعدي داتا معينة debounceTime يقلل عدد الـ events (مهم في search مثلًا) switchMap لو فيه request جديد، يلغي القديم (مهم جدًا مع APIs) الميزة هنا إن كل حاجة declarative يعني انت بتوصف "عايز إيه يحصل" مش "إزاي يحصل خطوة خطوة" نيجي بقى للـ Subject الـ Observable العادي زي قناة بتتفرج عليها لكن مش بإيدك تغير اللي فيها إنما Subject عامل زي remote control تقدر تسمع منه وتقدر تبعت فيه data بنفسك (next) وده بيخليه مفيد جدًا في: مشاركة البيانات بين components state بسيطة event bus صغير جوه التطبيق