fleuvejs

FleuveJS

A simple Observable Utility library

Installation

npm i fleuvejs

How To Use

Instantiate a Fleuve

const johnDoe$ = new Fleuve({firstname: 'john', lastname: 'doe'});
const counter$ = new Fleuve(0);

Provide new values

const fleuve$ = new Fleuve(0);
fleuve$.next(12, 13, 14, 15, 16);
fleuve$.next((x) => x + 1, (x) => x * 2);

// This one will throw an error
fleuve$.next(12, (x) => x + 1);

Pipe the Fleuve

const fleuve$ = new Fleuve(18729);
const sum$ = fleuve$.pipe(
    (x) => (x + '').split(''), 
    (numbers) => numbers.reduce((acc, curr) => acc + curr, 0)
);

Subscribe

const fleuve$ = new Fleuve(12;
fleuve$.subscribe((value) => console.log(value));

// This one will throw an error
fleuve$.subscribe(42);