جاوااسکریپت - Node JS SSE: خطای observable در RxJs هنگام به اشتراک‌گذاری یک اشتراک نادیده گرفته می‌شود

یک نقطه پایانی SSE وجود دارد که اشتراک را به اشتراک می‌گذارد اگر مصرف‌کننده با همان کلید قبلاً مشترک شده باشد. اگر یک اشتراک فعال وجود داشته باشد، داده‌ها از یک مشتری دیگر دریافت می‌شوند.

مشکل این است که به نظر می‌رسد اشتراک بیرونی هیچ‌گاه خطا را دریافت نکر

ادامه مطلب →

انگولار - افزودن پویا به صف Observable در RXJS

هدف این است که صف درخواست‌های HTTP را به صورت پویا اضافه کنیم و صف را به عنوان یک درخواست مدیریت کنیم. اجازه دهید ابتدا وضعیت فعلی را نشان دهم.

کامپوننت.ts

public ngOnInit(): void { this.service.touched .pipe( filter(res => !!res),

ادامه مطلب →

جاوااسکریپت - چگونه یک تایمر rxjs را به صورت دستی تازه کنیم و پارامترهای observable را به‌روزرسانی کنیم؟

من در حال ساخت صفحه‌بندی یک وب‌سایت هستم که داده‌هایی را که هر ۲ دقیقه از یک API به‌روزرسانی می‌شوند، نمایش می‌دهد (API صفحه‌بندی شده است اما من نیاز دارم صفحه‌بندی خودم را انجام دهم تا داده‌ها را همان‌طور که می‌خواهم نشان دهم، مثال: ۱۰۰ عنصر در هر صفحه، صفحه ش

ادامه مطلب →

تایپ‌اسکریپت - انتخاب آرایه Observable در Rxjs بین مقادیر شروع و پایان داده شده

من یک آرایه Observable دارم که به این شکل است:

persons$: Observable<Person[]> = new Observable<Person[]>(); private personSource: BehaviorSubject<Person[]>; constructor() { this.personSource = new BehaviorSubject<Person[]>([ new Person('M

ادامه مطلب →

انگولار - چندین فراخوانی متوالی API با RxJs

من نیاز دارم که با استفاده از RxJs تماس‌های متوالی API انجام دهم. مسئله این است که ابتدا یک Observable آرایه‌ای ارسال می‌کند و برای هر آیتم از این آرایه باید یک URL سفارشی تنظیم کنم تا تماس بعدی انجام شود. در تماس دوم باید برخی شرایط را بررسی کرده و یک Observable بازگردانم. سوال من این است که چگونه می‌توانم برای هر عنصر آرایه، تماس انجام دهم د

ادامه مطلب →

typescript - بازسازی رویداد contextmenu در RxJS

من می‌خواهم رویداد contextmenu را از رویدادهای لمسی در RxJS بازسازی کنم زیرا iOS از رویداد contextmenu در لمس پشتیبانی نمی‌کند.

به زبان ساده، این observable باید منتشر شود وقتی:

  • رویداد touchstart رخ داد
  • برای ۲۰۰۰ میلی‌ثانیه (عملاً فشار طولانی)
  • به دنبال touchend

نباید در موارد زیر منتشر شود:

typescript - هدف از عملگرهای map تو در تو در RxJS چیست؟

من در حال حاضر در یک دوره آنلاین Angular شرکت می‌کنم و متوجه شدم که RxJS در توسعه وب بسیار گسترده استفاده می‌شود. من در حال آزمایش بودم و با یک عملگر map تو در تو برخورد کردم و تا حدی می‌توانم معنای اتفاقی که می‌افتد را درک کنم اما به نظر نمی‌رسد اطلاعات زیادی در مورد آن پیدا کنم.

this.productS

ادامه مطلب →

تایپ‌اسکریپت - آیا اپراتور RxJS وجود دارد که آخرین مقدار را هنگام مشترک شدن ارسال کند و به ارسال مقادیر جدید ادامه دهد؟

من نیاز دارم یک اپراتور rxjs بسازم که آن را latest نام بگذارم. در اینجا یک مثال از تست Karma که نحوه استفاده را نشان می‌دهد آورده شده است:

const root = new Subject<string>(); const inner = new Subject<number>(); co

ادامه مطلب →

جاوااسکریپت - استفاده از RxJS fromEvent و @ViewChild در مقابل رویداد keyup و RxJS Subject برای تغییرات مقدار فیلد ورودی

من یک جزء ساده دارم که با استفاده از مقادیری که در کادر جستجو تایپ می‌شوند، جستجو انجام می‌دهد. من دو روش مختلف برای نوشتن این کد پیدا کردم و هر دو کار می‌کنند.

روش 1 از fromEvent در RxJS استفاده می‌کند و یک observable ایجاد می‌کند تا ت

ادامه مطلب →

تایپ‌اسکریپت: RXJS `distinctUntilChanged` با حالت strict/پارامتر اول undefined کار نمی‌کند

کد زیر کار نمی‌کند:

let observable: Observable<{ key: number }> = of({ key: 123 }); observable.pipe( distinctUntilChanged(undefined, v => v.key) );

اگرچه بار اضافی وجود دارد:

export function distinctUntilCh

ادامه مطلب →