ReactiveX

بالنسبة لتسلسلات البيانات، يجمع هذا الأسلوب بين مزايا المُكرِّرات ومرونة البرمجة غير المتزامنة القائمة على الأحداث. كما أنه يعمل كوعد بسيط، مما يُزيل التعقيدات الناتجة عن طبقات متعددة من الاستدعاءات.

ReactiveX عبارة عن مزيج من الأفكار المستوحاة من أنماط المراقب والمكرر ومن البرمجة الوظيفية . ^{[ 2 ]}

يشترك المراقب في تسلسل قابل للمراقبة. ثم يرسل التسلسل العناصر إلى المراقب واحدًا تلو الآخر، عادةً عن طريق استدعاء دالة رد الاتصال المُقدمة. يتعامل المراقب مع كل عنصر قبل معالجة العنصر التالي. إذا وردت أحداث كثيرة بشكل غير متزامن، فيجب تخزينها في قائمة انتظار أو تجاهلها. في ReactiveX، لن يتم استدعاء المراقب أبدًا بعنصر خارج الترتيب، أو (في سياق متعدد الخيوط) قبل أن تُعيد دالة رد الاتصال قيمة العنصر السابق. تبقى الاستدعاءات غير المتزامنة غير متزامنة، ويمكن التعامل معها عن طريق إرجاع كائن قابل للمراقبة.

يشبه هذا النمط نمط المُكرِّرات، ففي حال حدوث خطأ فادح، يُبلغ المُراقب بشكل منفصل (عن طريق استدعاء دالة ثانية). وعند إرسال جميع العناصر، يكتمل (ويُبلغ المُراقب عن طريق استدعاء دالة ثالثة). كما تستعير واجهة برمجة تطبيقات Reactive Extensions العديد من عواملها من عوامل المُكرِّرات في لغات برمجة أخرى.

تختلف الامتدادات التفاعلية عن البرمجة التفاعلية الوظيفية كما هو موضح في مقدمة الامتدادات التفاعلية:

يُطلق عليها أحيانًا اسم "البرمجة التفاعلية الوظيفية"، لكن هذا المصطلح غير دقيق. قد تكون ReactiveX وظيفية، وقد تكون تفاعلية، لكن "البرمجة التفاعلية الوظيفية" تختلف عنها تمامًا. أحد الفروق الرئيسية هو أن البرمجة التفاعلية الوظيفية تعمل على قيم تتغير باستمرار مع مرور الوقت، بينما تعمل ReactiveX على قيم منفصلة تُصدر على مدار الوقت. (للحصول على معلومات أكثر دقة حول البرمجة التفاعلية الوظيفية، يُرجى مراجعة أعمال كونال إليوت). ^{[ 2 ]}

المعامل هو دالة تأخذ كائنًا قابلًا للملاحظة (المصدر) كمعامل أول، وتعيد كائنًا قابلًا للملاحظة آخر (الوجهة، أو الكائن الخارجي). ثم، لكل عنصر يصدره الكائن المصدر، تُطبق الدالة عليه، ثم تُصدره على الكائن الوجهة. بل يمكنها أيضًا إصدار كائن آخر على الكائن الوجهة. يُسمى هذا الكائن بالكائن الداخلي.

يمكن أن يتبع عاملٌ يُصدر متغيرات داخلية عاملٌ آخر يجمع بطريقةٍ ما العناصر الصادرة عن جميع المتغيرات الداخلية ويُصدر العنصر على متغيره الخارجي. ومن الأمثلة على ذلك:

• switchAll– يشترك في كل عنصر داخلي قابل للملاحظة جديد بمجرد إصداره، ويلغي اشتراكه في العنصر السابق.
• mergeAll– يشترك في جميع المتغيرات الداخلية القابلة للملاحظة عند إصدارها ويخرج قيمها بأي ترتيب يستقبلها به.
• concatAll- يشترك في كل عنصر قابل للملاحظة داخليًا بالترتيب وينتظر اكتماله قبل الاشتراك في العنصر القابل للملاحظة التالي.

يمكن ربط عوامل التشغيل معًا لإنشاء تدفقات بيانات معقدة تقوم بتصفية الأحداث بناءً على معايير محددة. ويمكن تطبيق عوامل تشغيل متعددة على نفس العنصر القابل للملاحظة.

قد تكون بعض العمليات التي يمكن استخدامها في Reactive Extensions مألوفة للمبرمجين الذين يستخدمون لغات البرمجة الوظيفية، مثل map وreduce وgroup وzip. ^{[ 3 ]} تتوفر العديد من العمليات الأخرى في Reactive Extensions، على الرغم من أن العمليات المتاحة في تطبيق معين للغة برمجة معينة قد تختلف.

import { of , Observable , map , reduce } from 'rxjs' ;const source : Observable <number> = of ( 1 , 2 , 3 , 4 , 5 ) ; source.pipe ( map ( ( value ) => value * 2 ) , reduce (( sum , value ) = > sum + value , 0 ) ) . subscribe ({ next : ( value ) => { console.log ( value ); }, error : ( error ) => { console.error ( error ) ; }, complete : ( ) => { console.log ( ' done ' ) ; } , } );

import { BehaviorSubject , scan } from 'rxjs' ; import { rml } from 'rimmel' ;const count = new BehaviorSubject ( 0 ). pipe ( scan ( x => x + 1 ) );document.body.innerHTML = rml `  <buttonsi" id="mwATA">${ counter } " >انقر</ button > <p>  العدد هو: <span> ${ count } </span></p> ` ;