wonka

import { pipe, fromArray, map, filter, subscribe, make } from 'wonka'; // 1. Create a simple stream from an array, transform it, and log values const numberStream = pipe( fromArray([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]), filter(n => n % 2 === 0), // Keep only even numbers map(n => n * 2), // Double them subscribe(value => { console.log(`Array Stream: ${value}`); }) ); // For demonstration, manually unsubscribe after some time (optional for finite streams) // setTimeout(() => numberStream.unsubscribe(), 100); // 2. Create a custom interval stream that emits a few values const intervalSource = (intervalMs: number) => make<number>(({ next, complete }) => { let count = 0; const id = setInterval(() => { if (count < 3) { // Emit 3 values then complete next(count++); } else { complete(); // Signal completion clearInterval(id); } }, intervalMs); return () => clearInterval(id); // Teardown logic }); const intervalPipeline = pipe( intervalSource(1000), // Emit every second map(val => `Custom Interval Stream: ${val}`), subscribe(console.log) ); // The interval stream will automatically complete and clean up after 3 emissions.