25 lines
506 B
TypeScript
25 lines
506 B
TypeScript
import { NopeObservable } from "../lib/observables/nopeObservable";
|
|
|
|
const observable = new NopeObservable<number>();
|
|
observable.setContent(0);
|
|
const observer = observable.subscribe({
|
|
next: (...args) => {
|
|
console.log("Received the data", ...args);
|
|
}
|
|
});
|
|
|
|
const max = 10;
|
|
let i = 1;
|
|
|
|
while (i <= max) {
|
|
observable.setContent(i);
|
|
i++;
|
|
}
|
|
|
|
i = 10;
|
|
|
|
observable.subscribe((...args) => {
|
|
console.log("shoud not receive 10:", ...args);
|
|
}, "sync", { skipCurrent: true });
|
|
|
|
observable.setContent(1337); |