import { interval, of } from 'rxjs';
import { expand, take } from 'rxjs/operators';
const example = source.pipe(
//recursively call supplied function
console.log(`Passed value: ${val}`);
const subscribe = example.subscribe(val => console.log(`RESULT: ${val}`));