Baconjs Bacon.update function for Rxjs v5
npm install rx-observable-update
npm install rx-observable-update --save
`
jspm
If you use commonjs module resolution.
`
jspm install npm:rx-observable -o "{main: 'commonjs/index.js'}"
`
If you use systemjs module resolution.
`
jspm install npm:rx-observable -o "{main: 'systemjs/index.js'}"
`
For typescript user
Set paths options for tsconfig as like following.
`
{
"compilerOptions": {
"baseUrl": "./",
"paths": {
"rx-observable-update": ["jspm_packages/npm/rx-observable-update/index.ts"]
}
}
}
`
After set paths options like above, you can import like following.
`
import update from 'rx-observable-update';
`
Usage
Like baconjs update function,
`
import {
Subject
} from 'rxjs/Rx';
import update from 'rx-observable-update';
const source1 = new Subject();
const source2 = new Subject();
const source3 = new Subject();
update(
1,
source1, (oldValue, newValue) => {return oldValue + newValue},
source2, (oldValue, newValue) => {return oldValue + newValue},
source3, (oldValue, newValue) => {return oldValue + newValue},
).subscribe(value => {
console.log(value);
});
source1.next(2);
source2.next(3);
source3.next(4);
// Output 3, 6, 10
``