التكامل بين RxJS والإشارات

import { switchMap } from "rxjs";
import { TestScheduler } from "rxjs/testing";
const scheduler = new TestScheduler((actual, expected) => {
  if (JSON.stringify(actual) !== JSON.stringify(expected)) { throw new Error("schedule mismatch"); }
});
scheduler.run(({ cold, expectObservable }) => {
  const queries = cold("a-b----|", { a: "first", b: "second" });
  const result = queries.pipe(switchMap(query => cold("---x|", { x: query })));
  expectObservable(result).toBe("-----b-|", { b: "second" });
});
console.log("1 schedule passed");

1 schedule passed

تصدر second وحدها بالجدول ويظهر النجاح بعد صحة مقارنة الإشعارات.

import { Injector, runInInjectionContext } from "@angular/core";
import { toSignal } from "@angular/core/rxjs-interop";
import { of } from "rxjs";
const owner = Injector.create({ providers: [] });
const latest = runInInjectionContext(owner, () => toSignal(of(1, 2, 3), { initialValue: 0 }));
console.log(latest());
owner.destroy();

3

الأحدث المتزامن ثلاثة، ويفحص الجسر وملكيته لا عرضًا أو HTTP غير متزامنة.