أنجولار - إرجاع نتيجة مرصد باستخدام combineLatest و Rxjs
أتمنى الحصول على نتيجة لمراقب يقوم بطرح القيمة الافتراضية في كل مرة يتغير فيها القيمة
في كل مرة تتغير القيمة، يتم طرح القيمة الافتراضية من القيمة الجديدة المُدخلة في حقل الإدخال
على سبيل المثال، القيمة الافتراضية هي 5.
أدخل 4 في حقل الإدخال
النتيجة هي 5-4=1 لذلك أرغب في عر
اقرأ أكثر →angular - كيف تصل إلى Rx.Scheduler.immediate عبر rxjs باستخدام SystemJS/Angular2؟
أود استخدام ImmediateScheduler من RxJS في مشروعي Angular2.
ومع ذلك، في تثبيت RxJS الخاص بي، هذا غير موجود. أنا أستخدم "rxjs": "5.0.0-beta.12" في ملف package.json الخاص بي والذي يُطلب من قبل Angular 2.1.2.
عند النظر في مجلد node_modules/ أجد مجلداً باسم 'rxjs' ومجلداً باسم 'rx'. ImmediateScheduler ليست جزءًا من 'rxjs' ولكنها جزء من 'rx'. أستطيع أن أجدها هناك في 'rx/dist/rx.lite.js' أو حتى في 'rx/ts/rx/rx-lite.ts' كـ TypeScript الذي أستخدمه.
محاولة استيراده في ملف TypeScript الخ
اقرأ أكثر →تايب سكريبت - Rxjs: اختصار لإنشاء Observable من قيمة أو Observable
أنا أستخدم rxjs مع تايبسكريبت. كتبت الوظيفتين البسيطتين التاليتين. ولكن أعتقد أن rxjs لديه بالفعل مثل هذه الوظائف. هل لدى rxjs ذلك؟
export function isObservable(value: any): value is Observable<any> { return value instanceof Observa اقرأ أكثر →تايبسكريبت - فايربيس و RxJS
لقد أنشأت دالة تستمع إلى أحداث القيمة:
getUnreadMessages() : Observable<any>{ return new Observable(observer =>{ firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{ let count = 0; ...some more logic here... observer.next(count); observer.complete(); }, (error) =>{ observer.error(error); }) }) }عندما تتغير قاعدة البيانات، أستطيع أ
اقرأ أكثر →أنغولار - مشغلات RXJS لا تعمل مع فايربيس
أنا أستخدم مشغلات RXJS مع المراقب الخاص بـ Firebase (distinct و filter). هذا هو شجرة Firebase الخاصة بي هنا. هذا هو الكود الخاص بي:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) اقرأ أكثر →جافاسكريبت - TypeScript يقوم بحل وحدة 'rxjs' بشكل مختلف في نفس الملف
لقد قضيت ساعات وأنا أدور في حلقات، لذا حان الوقت لسؤال غامض آخر.
أنا داخل مستودع أحادي lerna، مع مشروعين فرعيين، ProjectA و ProjectB.
ProjectA له اعتماد على rxjs، وكذلك ProjectB.
ProjectB
اقرأ أكثر →TypeScript - RxJS6: إعادة تعيين التدفق بعد الانتهاء
لقد كنت ألعب قليلاً بـ RxJS 6. أحاول تنفيذ dragstart, dragmove و dragend. هذا هو الكود الذي لدي حتى الآن.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from 'rxjs/internal/oper اقرأ أكثر →تايبسكريبت - مع RxJs في Angular، هل أحتاج فقط إلى إنهاء الـ Observables التي تم إنشاؤها في المكون؟
بشكل أساسي، ما زلت غير متأكد حقًا من تنظيف الكود التفاعلي في مكونات Angular. هل القواعد التالية صحيحة وكافية؟
قواعدي لمكوّن تفاعلي:
على الدليل x.subscribe():
- إذا كنت تستخدم x.takeUntil(...) أو بناءً مشابهًا، فلا حاجة لأي تنظيف يدوي
- إذا تم استدعاء x.complete() في نطاق المكون، فلن يكون هناك حاجة لتنظيف يدوي
- أو يدوياً .unsubscribe() عند الطلب أو في ngOnDestroy()
على قالب observabl
اقرأ أكثر →TypeScript - RxJS الترقيم مع الاشتراك في كل صفحة
نحن نقوم بالاستعلام من graphql عبر websocket للحصول على اشتراك في قائمة من الكيانات. نستخدم التجزئة لأن القائمة من المفترض أن تكون قابلة للتمرير إلى ما لا نهاية. نريد أيضًا رؤية التغييرات التي تطرأ على قاعدة البيانات في الوقت الفعلي في القائمة على الواجهة الأمامية.
يمكن تصفية هذه القائمة وفرزها وتقسيمها إلى صفحات.
لدينا الصف SelectParams الذي يساعدنا على القيام بذلك:
export class SelectParams { page اقرأ أكثر →تايبسكريبت - Angular 6 خطأ عند استخدام RxJS: لا يمكن قراءة الخاصية 'call' من undefined
أنا أحاول ترحيل تطبيق Angular 5 إلى Angular 6 ولدي هذا الكتلة الواحدة من كود RxJS التي حيرتني. لقد قمت بالبحث على جوجل وقرأت مستندات RxJS بما فيه الكفاية لأعرف أنه يجب علي استخدام .pipe، لكن لا أستطيع فهم الصياغة بشكل صحيح.
يعيد الكود النتائج من استدعاء API أثناء كتابة المستخد
اقرأ أكثر →