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);
}