function runCanDeactivateChecks(
    checks: CanDeactivate[], futureRSS: RouterStateSnapshot, currRSS: RouterStateSnapshot,
    moduleInjector: Injector): Observable<boolean> {
  return from(checks).pipe(
      mergeMap(
          (check: CanDeactivate) =>
              runCanDeactivate(check.component, check.route, currRSS, futureRSS, moduleInjector)),
      every((result: boolean) => result === true));
}

 every2() {
   // emit 5 values
   const allEvens = of(2, 4, 6, 8, 10);
   const example = allEvens.pipe(
     // is every value even?
     every(val => val % 2 === 0)
   );
   // output: true
   const subscribe = example.subscribe(val => console.log(val));
 }

 every1() {
   // emit 5 values
   const source = of(1, 2, 3, 4, 5);
   const example = source.pipe(
     // is every value even?
     every(val => val % 2 === 0)
   );
   // output: false
   const subscribe = example.subscribe(val => console.log(val));
 }

function runCanActivateChecks(
    futureSnapshot: RouterStateSnapshot, checks: CanActivate[], moduleInjector: Injector,
    forwardEvent?: (evt: Event) => void): Observable<boolean> {
  return from(checks).pipe(
      concatMap((check: CanActivate) => andObservables(from([
                  fireChildActivationStart(check.route.parent, forwardEvent),
                  fireActivationStart(check.route, forwardEvent),
                  runCanActivateChild(futureSnapshot, check.path, moduleInjector),
                  runCanActivate(futureSnapshot, check.route, moduleInjector)
                ]))),
      every((result: boolean) => result === true));
}

function runCanDeactivate(
    component: Object | null, currARS: ActivatedRouteSnapshot, currRSS: RouterStateSnapshot,
    futureRSS: RouterStateSnapshot, moduleInjector: Injector): Observable<boolean> {
  const canDeactivate = currARS && currARS.routeConfig ? currARS.routeConfig.canDeactivate : null;
  if (!canDeactivate || canDeactivate.length === 0) return of (true);
  const canDeactivate$ = from(canDeactivate).pipe(mergeMap((c: any) => {
    const guard = getToken(c, currARS, moduleInjector);
    let observable: Observable<boolean>;
    if (guard.canDeactivate) {
      observable = wrapIntoObservable(guard.canDeactivate(component, currARS, currRSS, futureRSS));
    } else {
      observable = wrapIntoObservable(guard(component, currARS, currRSS, futureRSS));
    }
    return observable.pipe(first());
  }));
  return canDeactivate$.pipe(every((result: any) => result === true));
}

it('should support index and its type', () => {
  const a = of(1, 2, 3).pipe(every((val, index: number) => val < 3)); // $ExpectType Observable<boolean>
});