یک نقطه پایانی SSE وجود دارد که اشتراک را به اشتراک میگذارد اگر مصرفکننده با همان کلید قبلاً مشترک شده باشد. اگر یک اشتراک فعال وجود داشته باشد، دادهها از یک مشتری دیگر دریافت میشوند.
مشکل این است که به نظر میرسد اشتراک بیرونی هیچگاه خطا را دریافت نکر
ادامه مطلب →
هدف این است که صف درخواستهای HTTP را به صورت پویا اضافه کنیم و صف را به عنوان یک درخواست مدیریت کنیم. اجازه دهید ابتدا وضعیت فعلی را نشان دهم.
کامپوننت.ts
public ngOnInit(): void { this.service.touched .pipe( filter(res => !!res), ادامه مطلب →
من در حال ساخت صفحهبندی یک وبسایت هستم که دادههایی را که هر ۲ دقیقه از یک API بهروزرسانی میشوند، نمایش میدهد (API صفحهبندی شده است اما من نیاز دارم صفحهبندی خودم را انجام دهم تا دادهها را همانطور که میخواهم نشان دهم، مثال: ۱۰۰ عنصر در هر صفحه، صفحه ش
ادامه مطلب →
من یک آرایه Observable دارم که به این شکل است:
persons$: Observable<Person[]> = new Observable<Person[]>(); private personSource: BehaviorSubject<Person[]>; constructor() { this.personSource = new BehaviorSubject<Person[]>([ new Person('M ادامه مطلب →
من نیاز دارم که با استفاده از RxJs تماسهای متوالی API انجام دهم. مسئله این است که ابتدا یک Observable آرایهای ارسال میکند و برای هر آیتم از این آرایه باید یک URL سفارشی تنظیم کنم تا تماس بعدی انجام شود. در تماس دوم باید برخی شرایط را بررسی کرده و یک Observable بازگردانم. سوال من این است که چگونه میتوانم برای هر عنصر آرایه، تماس انجام دهم د
ادامه مطلب →
من میخواهم رویداد contextmenu را از رویدادهای لمسی در RxJS بازسازی کنم زیرا iOS از رویداد contextmenu در لمس پشتیبانی نمیکند.
به زبان ساده، این observable باید منتشر شود وقتی:
نباید در موارد زیر منتشر شود:
من در حال حاضر در یک دوره آنلاین Angular شرکت میکنم و متوجه شدم که RxJS در توسعه وب بسیار گسترده استفاده میشود. من در حال آزمایش بودم و با یک عملگر map تو در تو برخورد کردم و تا حدی میتوانم معنای اتفاقی که میافتد را درک کنم اما به نظر نمیرسد اطلاعات زیادی در مورد آن پیدا کنم.
this.productS ادامه مطلب →
من نیاز دارم یک اپراتور rxjs بسازم که آن را latest نام بگذارم. در اینجا یک مثال از تست Karma که نحوه استفاده را نشان میدهد آورده شده است:
const root = new Subject<string>(); const inner = new Subject<number>(); co ادامه مطلب →
من یک جزء ساده دارم که با استفاده از مقادیری که در کادر جستجو تایپ میشوند، جستجو انجام میدهد. من دو روش مختلف برای نوشتن این کد پیدا کردم و هر دو کار میکنند.
روش 1 از fromEvent در RxJS استفاده میکند و یک observable ایجاد میکند تا ت
ادامه مطلب →
کد زیر کار نمیکند:
let observable: Observable<{ key: number }> = of({ key: 123 }); observable.pipe( distinctUntilChanged(undefined, v => v.key) );اگرچه بار اضافی وجود دارد:
export function distinctUntilCh ادامه مطلب →