rx-sandbox

import { createSandbox } from 'rx-sandbox'; import { map, take } from 'rxjs/operators'; function runRxSandboxTest() { // Initialize the sandbox, destructuring common utilities for convenience. const { get, cold, hot, expectObservable, expectSubscriptions } = createSandbox(); // Example 1: Testing a cold observable transformation // 'cold' creates an observable that starts emitting when subscribed. const source$ = cold('-a-b-c|', { a: 1, b: 2, c: 3 }); const mapped$ = source$.pipe(map(x => x * 10)); // 'expectObservable' asserts the output using marble syntax and a value map. expectObservable(mapped$).toBe('-A-B-C|', { A: 10, B: 20, C: 30 }); // Example 2: Testing a hot observable with subscription points and unsubscription // 'hot' creates an observable that is already active when subscribed. const hotSource$ = hot('--a--b--c--d|'); // 'sub' defines the subscription (^) and unsubscription (!) frames. const sub = '^----------!'; // Subscribes at frame 0, unsubscribes at frame 10 const result$ = hotSource$.pipe(take(3), map(x => x.toUpperCase())); // Assert the observable's output and verify its subscription behavior. expectObservable(result$, sub).toBe('--A--B--C|', { A: 'A', B: 'B', C: 'C' }); expectSubscriptions(hotSource$.subscriptions).toBe(sub); console.log('RxSandbox tests are defined. In a real test runner (e.g., Jest, Mocha),'); console.log('these assertions would automatically execute and report outcomes.'); } // Execute the test function. In a typical test suite, this would be within `it()` blocks. runRxSandboxTest();