Observable cache

ObservableCache.ts

let cache = (source: Observable<any>) => {
	let replay: ReplaySubject<any>;

	return source
		.multicast(() => {
			if (!replay) {
				replay = new ReplaySubject(2);

				setTimeout(() => replay = null, 2500);
			}

			return replay;
		})
		.refCount();
}