Test Observable.
This commit is contained in:
parent
bdc485977d
commit
60f48a3910
@ -1,21 +1,28 @@
|
|||||||
import { filter } from 'rxjs/operators';
|
import { filter } from 'rxjs/operators';
|
||||||
import { nopeObservable } from "../lib/observables/nopeObservable";
|
import { nopeObservable } from "../lib/observables/nopeObservable";
|
||||||
|
|
||||||
const observable = new nopeObservable(0);
|
const observable = new nopeObservable<number>();
|
||||||
const subscriptionSmaller = observable.pipe(
|
const subscriptionSmaller = observable.observable.pipe(
|
||||||
filter((v, idx) => v < 10)
|
filter((v, idx) => v < 10)
|
||||||
).subscribe((v) => {
|
).subscribe((v) => {
|
||||||
console.log('smaller 10:', v)
|
console.log('smaller 10:', v)
|
||||||
});
|
});
|
||||||
|
|
||||||
const subscriptionGreater = observable.pipe(
|
const subscriptionGreater = observable.observable.pipe(
|
||||||
filter((v, idx) => v > 10)
|
filter((v, idx) => v > 10)
|
||||||
).subscribe((v) => {
|
).subscribe((v) => {
|
||||||
console.log('greater 10: ', v)
|
console.log('greater 10: ', v)
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const subEnhanced = observable.enhancedSubscription((v) => console.log('enhanced', v), {
|
||||||
|
pipe: (scope, observable) => {
|
||||||
|
return observable.pipe(filter((v, idx) => v > 10))
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
let i = 1;
|
let i = 1;
|
||||||
while (i < 20) {
|
while (i < 20) {
|
||||||
observable.currentValue = i++;
|
observable.value = i++;
|
||||||
console.log('current', observable.currentValue);
|
console.log('current', observable.value);
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user