import { exhaustMap } from 'rxjs/operators' ; import { Observable , timer } from 'rxjs' ; param interval export const keepFresh = ( interval ) => < T > ( source ) => { const trigger = timer ( 0 , interval ) ; return trigger . pipe ( exhaustMap ( ( ) => source ) ) ; } ;