21 lines
530 B
TypeScript
21 lines
530 B
TypeScript
|
import { filter } from 'rxjs/operators';
|
||
|
|
import { nopeObservable } from "../lib/observables/nopeObservable";
|
||
|
|
|
||
|
|
const observable = new nopeObservable(0);
|
||
|
|
const subscriptionSmaller = observable.pipe(
|
||
|
|
filter((v, idx) => v < 10)
|
||
|
|
).subscribe((v) => {
|
||
|
|
console.log('smaller 10:', v)
|
||
|
|
});
|
||
|
|
|
||
|
|
const subscriptionGreater = observable.pipe(
|
||
|
|
filter((v, idx) => v > 10)
|
||
|
|
).subscribe((v) => {
|
||
|
|
console.log('greater 10: ', v)
|
||
|
|
});
|
||
|
|
|
||
|
|
let i = 1;
|
||
|
|
while (i < 20) {
|
||
|
|
observable.currentValue = i++;
|
||
|
|
console.log('current', observable.currentValue);
|
||
|
|
}
|